Flux
Flux is a Project Reactor publisher type representing an asynchronous sequence that emits zero or more ordered values.
Spring in Action, Sixth Edition
Flux is Project Reactor's publisher type for asynchronously emitting zero or more ordered elements.
- How it is used
- Represents asynchronous pipelines that publish zero or more elements and support reactive composition.
- How deep it goes
- Explains Flux fundamentals and selected creation, combination, and transformation operations, but stops short of surveying all available operations.
- Examples
- Uses delayed character and food streams, mergeWith(), zip(), firstWithSignal(), and StepVerifier tests.
- What you can do after
- Apply it via Project Reactor to build, combine, subscribe to, and test asynchronous data pipelines.
Spring Security in Action, Second Edition
Flux is a Project Reactor publisher that emits zero or more values asynchronously.
- How it is used
- Represents multiple values returned progressively by a reactive web endpoint.
- How deep it goes
- Defines Flux as a multiple-value publisher and contrasts it with Mono, without detailing implementation internals.
- Examples
- Uses a milk-factory analogy in which multiple bottles are produced and delivered as milk arrives.
- What you can do after
- Evaluate/understand when a reactive endpoint requires a publisher for multiple values instead of a single value.
Read how Spring Security in Action, Second Edition explains Flux →
Spring AI in Action
Flux is a Project Reactor reactive type that emits zero or more data elements asynchronously as they become available.
- How it is used
- Streams generated chat responses progressively to improve user feedback during longer LLM operations.
- How deep it goes
- Defines zero-to-many reactive emission and demonstrates service-controller integration, while deferring broader Project Reactor details.
- Examples
- Uses a board-game question service, streamed battle-card answers, Flux<String>, and HTTPie demonstrations.
- What you can do after
- Apply Flux through ChatClient stream(), reactive return types, and streamed endpoint configuration.
Related concepts
- producerkind of · A producer is an entity or process that creates or supplies values, data, messages, events, or work for another entity to consume.
- allused by · An all operation returns a Boolean indicating whether every item in a collection satisfies a condition, or is truthy when no condition is specified.
- bodyToFlux()produced by · bodyToFlux() is a WebClient response operation that converts a response body into a Flux of a specified type.
These guides are generated from the text of Manning books by Manning's knowledge graph and link to the sections they draw on. The full books are available on liveBook and at manning.com.