Class JdkFlowAdapters
- java.lang.Object
-
- io.servicetalk.concurrent.jdkflow.JdkFlowAdapters
-
public final class JdkFlowAdapters extends java.lang.ObjectA set of adapter methods for converting to and from JDK Flow APIs and ServiceTalk APIs.
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> Publisher<T>fromFlowPublisher(java.util.concurrent.Flow.Publisher<T> source)static <T> java.util.concurrent.Flow.Publisher<T>toFlowPublisher(Publisher<T> publisher)static <T> java.util.concurrent.Flow.Publisher<T>toFlowPublisher(PublisherSource<T> source)
-
-
-
Method Detail
-
fromFlowPublisher
public static <T> Publisher<T> fromFlowPublisher(java.util.concurrent.Flow.Publisher<T> source)
-
toFlowPublisher
public static <T> java.util.concurrent.Flow.Publisher<T> toFlowPublisher(Publisher<T> publisher)
-
toFlowPublisher
public static <T> java.util.concurrent.Flow.Publisher<T> toFlowPublisher(PublisherSource<T> source)
- Type Parameters:
T- Type of items emitted from thesourceand the returnedFlow.Publisher.- Parameters:
source-PublisherSourceto convert to aFlow.Publisher.- Returns:
- A
Flow.Publisherrepresentation of the passedPublisherSource.
-
-