com.github.davidmoten.rx2.internal.flowable.buffertofile

Class FlowableOnBackpressureBufferToFile.BufferToFileSubscriberFlowable<T>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

com.github.davidmoten.rx2.internal.flowable.buffertofile.FlowableOnBackpressureBufferToFile.BufferToFileSubscriberFlowable<T>

All Implemented Interfaces:

io.reactivex.FlowableSubscriber<T>, Serializable, Runnable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription

Enclosing class:

FlowableOnBackpressureBufferToFile<T>

public static final class FlowableOnBackpressureBufferToFile.BufferToFileSubscriberFlowable<T>
extends AtomicInteger
implements io.reactivex.FlowableSubscriber<T>, org.reactivestreams.Subscription

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	cancelled
protected org.reactivestreams.Subscriber<? super T>	child
protected AtomicLong	requested

Constructor Summary

Constructors

Constructor and Description
BufferToFileSubscriberFlowable(org.reactivestreams.Subscriber<? super T> child, PagedQueue queue, Serializer<T> serializer, io.reactivex.Scheduler.Worker worker)

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	cancelUpstream()
void	onComplete()
void	onError(Throwable e)
void	onNext(T t)
void	onSubscribe(org.reactivestreams.Subscription parent)
void	request(long n)
void	run()
protected void	scheduleDrain()

Methods inherited from class java.util.concurrent.atomic.AtomicInteger

accumulateAndGet, addAndGet, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, incrementAndGet, intValue, lazySet, longValue, set, toString, updateAndGet, weakCompareAndSet

Methods inherited from class java.lang.Number

byteValue, shortValue

Methods inherited from class java.lang.Object

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

Field Detail

child

protected final org.reactivestreams.Subscriber<? super T> child

requested

protected final AtomicLong requested

cancelled

protected volatile boolean cancelled

Constructor Detail

BufferToFileSubscriberFlowable

public BufferToFileSubscriberFlowable(org.reactivestreams.Subscriber<? super T> child,
                                      PagedQueue queue,
                                      Serializer<T> serializer,
                                      io.reactivex.Scheduler.Worker worker)

Method Detail

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription parent)

Specified by:

onSubscribe in interface io.reactivex.FlowableSubscriber<T>

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

onNext

public void onNext(T t)

Specified by:

onNext in interface org.reactivestreams.Subscriber<T>

onError

public void onError(Throwable e)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>

cancelUpstream

public void cancelUpstream()

scheduleDrain

protected void scheduleDrain()

run

public void run()

Specified by:

run in interface Runnable