Module mutiny.zero

Package mutiny.zero.operators

Class Select<T>

java.lang.Object

mutiny.zero.operators.Select<T>

Type Parameters:

T - the elements type

All Implemented Interfaces:

Flow.Publisher<T>

public class Select<T>
extends Object
implements Flow.Publisher<T>

A Flow.Publisher that selects elements matching a Predicate.

Constructor Summary

Constructors

Constructor	Description
Select(Flow.Publisher<T> upstream, Predicate<T> predicate)	Build a new selection publisher.

Method Summary

Modifier and Type	Method	Description
void	subscribe(Flow.Subscriber<? super T> subscriber)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Select

public Select(Flow.Publisher<T> upstream,
 Predicate<T> predicate)

Build a new selection publisher.

Parameters:

upstream - the upstream publisher

predicate - the predicate to select the elements forwarded to subscribers, must not throw exceptions

Method Details

subscribe

public void subscribe(Flow.Subscriber<? super T> subscriber)

Specified by:

subscribe in interface Flow.Publisher<T>