Module mutiny.zero.flow.adapters
Package mutiny.zero.flow.adapters
Interface AdaptersToReactiveStreams
-
public interface AdaptersToReactiveStreamsAdapters fromFlowtypes 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.Processorto aProcessor.static <T> org.reactivestreams.Publisher<T>publisher(java.util.concurrent.Flow.Publisher<T> publisher)Convert aFlow.Publisherto aPublisher.static <T> org.reactivestreams.Subscriber<T>subscriber(java.util.concurrent.Flow.Subscriber<T> subscriber)Convert aFlow.Subscriberto aSubscriber.static org.reactivestreams.Subscriptionsubscription(java.util.concurrent.Flow.Subscription subscription)Convert aFlow.Subscriptionto aSubscription.
-
-
-
Method Detail
-
publisher
static <T> org.reactivestreams.Publisher<T> publisher(java.util.concurrent.Flow.Publisher<T> publisher)
Convert aFlow.Publisherto 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.Subscriberto 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.Subscriptionto 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.Processorto aProcessor.- Type Parameters:
T- the items typeR- the output items type- Parameters:
processor- the processor- Returns:
- the wrapped processor
-
-