Class ObservableReadStream<T,​R>

    • Field Detail

      • DEFAULT_MAX_BUFFER_SIZE

        public static final long DEFAULT_MAX_BUFFER_SIZE
        See Also:
        Constant Field Values
    • Constructor Detail

      • ObservableReadStream

        public ObservableReadStream​(ReadStream<T> stream,
                                    java.util.function.Function<T,​R> adapter)
      • ObservableReadStream

        public ObservableReadStream​(ReadStream<T> stream,
                                    java.util.function.Function<T,​R> adapter,
                                    long maxBufferSize)
    • Method Detail

      • getRequested

        public long getRequested()