public class ObservableReadStream<T,R> extends Object implements Observable.OnSubscribe<R>
ReadStream
to be an Observable.OnSubscribe
that can be used to
build Observable
.
The adapter supports reactive pull back-pressure.
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_MAX_BUFFER_SIZE |
Constructor and Description |
---|
ObservableReadStream(ReadStream<T> stream,
java.util.function.Function<T,R> adapter) |
ObservableReadStream(ReadStream<T> stream,
java.util.function.Function<T,R> adapter,
long maxBufferSize) |
Modifier and Type | Method and Description |
---|---|
void |
call(Subscriber<? super R> subscriber) |
long |
getRequested() |
public static final long DEFAULT_MAX_BUFFER_SIZE
public ObservableReadStream(ReadStream<T> stream, java.util.function.Function<T,R> adapter)
public ObservableReadStream(ReadStream<T> stream, java.util.function.Function<T,R> adapter, long maxBufferSize)
public long getRequested()
public void call(Subscriber<? super R> subscriber)
call
in interface Action1<Subscriber<? super R>>
Copyright © 2023 Eclipse. All rights reserved.