Module mutiny.zero.flow.adapters
Package mutiny.zero.flow.adapters
Interface AdaptersToReactiveStreams
-
public interface AdaptersToReactiveStreams
Adapters fromFlow
types to Reactive Streams types.
-
-
Method Summary
Static Methods Modifier and Type Method Description static <T,R>
org.reactivestreams.Processor<T,R>processor(java.util.concurrent.Flow.Processor<T,R> processor)
Convert aFlow.Processor
to aProcessor
.static <T> org.reactivestreams.Publisher<T>
publisher(java.util.concurrent.Flow.Publisher<T> publisher)
Convert aFlow.Publisher
to aPublisher
.static <T> org.reactivestreams.Subscriber<T>
subscriber(java.util.concurrent.Flow.Subscriber<T> subscriber)
Convert aFlow.Subscriber
to aSubscriber
.static org.reactivestreams.Subscription
subscription(java.util.concurrent.Flow.Subscription subscription)
Convert aFlow.Subscription
to aSubscription
.
-
-
-
Method Detail
-
publisher
static <T> org.reactivestreams.Publisher<T> publisher(java.util.concurrent.Flow.Publisher<T> publisher)
Convert aFlow.Publisher
to aPublisher
.- Type Parameters:
T
- the items type- Parameters:
publisher
- the publisher- Returns:
- the wrapped publisher
-
subscriber
static <T> org.reactivestreams.Subscriber<T> subscriber(java.util.concurrent.Flow.Subscriber<T> subscriber)
Convert aFlow.Subscriber
to aSubscriber
.- Type Parameters:
T
- the items type- Parameters:
subscriber
- the subscriber- Returns:
- the wrapped subscriber
-
subscription
static org.reactivestreams.Subscription subscription(java.util.concurrent.Flow.Subscription subscription)
Convert aFlow.Subscription
to aSubscription
.- Parameters:
subscription
- the subscription- Returns:
- the wrapped subscription
-
processor
static <T,R> org.reactivestreams.Processor<T,R> processor(java.util.concurrent.Flow.Processor<T,R> processor)
Convert aFlow.Processor
to aProcessor
.- Type Parameters:
T
- the items typeR
- the output items type- Parameters:
processor
- the processor- Returns:
- the wrapped processor
-
-