hu.akarnokd.rxjava2.internal.operators

Class OperatorOnBackpressureBuffer<T>

java.lang.Object

hu.akarnokd.rxjava2.internal.operators.OperatorOnBackpressureBuffer<T>

All Implemented Interfaces:

Function<org.reactivestreams.Subscriber<? super T>,org.reactivestreams.Subscriber<? super T>>, Observable.Operator<T,T>

public final class OperatorOnBackpressureBuffer<T>
extends java.lang.Object
implements Observable.Operator<T,T>

Constructor Summary

Constructors

Constructor and Description
OperatorOnBackpressureBuffer(int bufferSize, boolean unbounded, boolean delayError, java.lang.Runnable onOverflow)

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Subscriber<? super T>	apply(org.reactivestreams.Subscriber<? super T> t)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OperatorOnBackpressureBuffer

public OperatorOnBackpressureBuffer(int bufferSize,
                                    boolean unbounded,
                                    boolean delayError,
                                    java.lang.Runnable onOverflow)

Method Detail

apply

public org.reactivestreams.Subscriber<? super T> apply(org.reactivestreams.Subscriber<? super T> t)

Specified by:

apply in interface Function<org.reactivestreams.Subscriber<? super T>,org.reactivestreams.Subscriber<? super T>>