Hands-On Reactive Programming in Spring 5

Filtering reactive sequences

Of course, Project Reactor contains all kinds of operators for filtering elements, such as:

• The filter operator passes only elements that satisfy the condition.
• The ignoreElements operator returns Mono<T> and filters out all elements. The resulting sequence ends only after the original ends.
• The library allows for the limiting of taken elements with the take(n) method, which ignores all elements except the first n.
• takeLast returns only the last element of the stream.
• takeUntil(Predicate) passes an element until some condition is satisfied.
• elementAt(n) allows the taking of only the n^th element of the sequence.
• The single operator emits a single item from the source and signals the NoSuchElementException error ...