public class FlowableHelper extends Object
Constructor and Description |
---|
FlowableHelper() |
Modifier and Type | Method and Description |
---|---|
static <T> Flowable<T> |
toFlowable(ReadStream<T> stream)
Adapts a Vert.x
ReadStream to an RxJava Flowable . |
static <T,U> Flowable<U> |
toFlowable(ReadStream<T> stream,
java.util.function.Function<T,U> mapping)
Like
toFlowable(ReadStream) but with a mapping function |
static <T> Flowable<T> |
toFlowable(ReadStream<T> stream,
long maxBufferSize)
Adapts a Vert.x
ReadStream to an RxJava Flowable . |
static <T> ReadStream<T> |
toReadStream(Flowable<T> observable)
Adapts an RxJava
Flowable to a Vert.x io.vertx.core.streams.ReadStream . |
static <T> FlowableTransformer<Buffer,T> |
unmarshaller(Class<T> mappedType) |
static <T> FlowableTransformer<Buffer,T> |
unmarshaller(Class<T> mappedType,
ObjectCodec mapper) |
static <T> FlowableTransformer<Buffer,T> |
unmarshaller(TypeReference<T> mappedTypeRef) |
static <T> FlowableTransformer<Buffer,T> |
unmarshaller(TypeReference<T> mappedTypeRef,
ObjectCodec mapper) |
public static <T> ReadStream<T> toReadStream(Flowable<T> observable)
Flowable
to a Vert.x io.vertx.core.streams.ReadStream
. The returned
readstream will be subscribed to the Flowable
.observable
- the observable to adaptpublic static <T,U> Flowable<U> toFlowable(ReadStream<T> stream, java.util.function.Function<T,U> mapping)
toFlowable(ReadStream)
but with a mapping
functionpublic static <T> Flowable<T> toFlowable(ReadStream<T> stream)
ReadStream
to an RxJava Flowable
. After
the stream is adapted to a flowable, the original stream handlers should not be used anymore
as they will be used by the flowable adapter.stream
- the stream to adaptpublic static <T> Flowable<T> toFlowable(ReadStream<T> stream, long maxBufferSize)
ReadStream
to an RxJava Flowable
. After
the stream is adapted to a flowable, the original stream handlers should not be used anymore
as they will be used by the flowable adapter.stream
- the stream to adaptpublic static <T> FlowableTransformer<Buffer,T> unmarshaller(Class<T> mappedType)
public static <T> FlowableTransformer<Buffer,T> unmarshaller(TypeReference<T> mappedTypeRef)
public static <T> FlowableTransformer<Buffer,T> unmarshaller(Class<T> mappedType, ObjectCodec mapper)
public static <T> FlowableTransformer<Buffer,T> unmarshaller(TypeReference<T> mappedTypeRef, ObjectCodec mapper)
Copyright © 2021 Eclipse. All rights reserved.