Spring Cloud Java 8功能支持

2024-01-06 11:15 更新

一般而言，用戶(hù)可以期望，如果他們?yōu)槠胀ǖ呐fJava類(lèi)型（或原始包裝器）編寫(xiě)函數(shù)，則函數(shù)目錄會(huì)將其包裝為相同類(lèi)型的Flux。如果用戶(hù)使用Message（通過(guò)spring-messaging）編寫(xiě)函數(shù)，它將從支持鍵值元數(shù)據(jù)的任何適配器接收和傳輸頭（例如HTTP頭）。這是詳細(xì)信息。

用戶(hù)功能	目錄注冊(cè)
`Function<S,T>`	`Function<Flux<S>, Flux<T>>`
`Function<Message<S>,Message<T>>`	`Function<Flux<Message<S>>, Flux<Message<T>>>`
`Function<Flux<S>, Flux<T>>`	`Function<Flux<S>, Flux<T>>` (pass through)
`Supplier<T>`	`Supplier<Flux<T>>`
`Supplier<Flux<T>>`	`Supplier<Flux<T>>`
`Consumer<T>`	`Function<Flux<T>, Mono<Void>>`
`Consumer<Message<T>>`	`Function<Flux<Message<T>>, Mono<Void>>`
`Consumer<Flux<T>>`	`Consumer<Flux<T>>`

消費(fèi)者有點(diǎn)特殊，因?yàn)樗幸粋€(gè)void返回類(lèi)型，這意味著至少有可能阻塞。很可能您不需要編寫(xiě)Consumer<Flux<?>>，但是如果需要這樣做，請(qǐng)記住訂閱輸入流量。如果聲明了非發(fā)布者類(lèi)型的Consumer（正常），它將被轉(zhuǎn)換為返回發(fā)布者的函數(shù)，以便可以通過(guò)受控方式進(jìn)行訂閱。

以上內(nèi)容是否對(duì)您有幫助：

← Spring Cloud 功能目錄和靈活的功能簽名

Spring Cloud Kotlin Lambda支持 →

寫(xiě)筆記

我要補(bǔ)充

Spring Cloud Java 8功能支持

推薦文章

推薦教程

推薦課程