SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Rename PollableSupplier to PollableBean in doc

Browse Source
This commit is contained in:
Hao Wang
2022-08-05 23:14:12 +08:00
committed by GitHub
parent e4b074b6d4
commit 05bef05540
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
docs/src/main/asciidoc/spring-cloud-function.adoc
View File

@@ -78,18 +78,18 @@ However, the same reactive suppliers can also represent _finite_ stream(s) (e.g.
In those cases such reactive suppliers must be hooked up to some polling mechanism of the underlying framework. In those cases such reactive suppliers must be hooked up to some polling mechanism of the underlying framework.
To assist with that Spring Cloud Function provides a marker annotation To assist with that Spring Cloud Function provides a marker annotation
`org.springframework.cloud.function.context.PollableSupplier` to signal that such supplier produces a `org.springframework.cloud.function.context.PollableBean` to signal that such supplier produces a
finite stream and may need to be polled again. That said, it is important to understand that Spring Cloud Function itself finite stream and may need to be polled again. That said, it is important to understand that Spring Cloud Function itself
provides no behavior for this annotation. provides no behavior for this annotation.
In addition `PollableSupplier` annotation exposes a _splittable_ attribute to signal that produced stream In addition `PollableBean` annotation exposes a _splittable_ attribute to signal that produced stream
needs to be split (see https://www.enterpriseintegrationpatterns.com/patterns/messaging/Sequencer.html[Splitter EIP]) needs to be split (see https://www.enterpriseintegrationpatterns.com/patterns/messaging/Sequencer.html[Splitter EIP])
Here is the example: Here is the example:
[source, java] [source, java]
---- ----
@PollableSupplier(splittable = true) @PollableBean(splittable = true)
public Supplier<Flux<String>> someSupplier() { public Supplier<Flux<String>> someSupplier() {
return () -> { return () -> {
String v1 = String.valueOf(System.nanoTime()); String v1 = String.valueOf(System.nanoTime());