Class JdkFlowAdapters
- java.lang.Object
-
- io.servicetalk.concurrent.jdkflow.JdkFlowAdapters
-
public final class JdkFlowAdapters extends java.lang.Object
A 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 thesource
and the returnedFlow.Publisher
.- Parameters:
source
-PublisherSource
to convert to aFlow.Publisher
.- Returns:
- A
Flow.Publisher
representation of the passedPublisherSource
.
-
-