RxJava 2 2.2.21 · io.reactivex.internal.util.QueueDrain

Method Summary

Modifier and Type	Method and Description
public boolean	Returns: true if the value was delivered accept(Subscriber<? super U> the subscriber a, T the value v) Accept the value and return true if forwarded.
public boolean	cancelled()
public boolean	done()
public boolean	enter()
public Throwable	error()
public int	Returns: the current value after adding m leave(int the value to add m) Adds m to the wip counter.
public long	produced(long n)
public long	requested()

accept	back to summary
public boolean accept(Subscriber<? super U> a, T v) Accept the value and return true if forwarded. Parameters a:Subscriber<? super U> the subscriber v:T the value Returns:boolean true if the value was delivered

public boolean accept(Subscriber<? super U> a, T v)

Accept the value and return true if forwarded.

Parameters

Returns:boolean

true if the value was delivered

cancelled	back to summary
public boolean cancelled()

done	back to summary
public boolean done()

enter	back to summary
public boolean enter()

error	back to summary
public Throwable error()

leave	back to summary
public int leave(int m) Adds m to the wip counter. Parameters m:int the value to add Returns:int the current value after adding m

leave

public int leave(int m)

Adds m to the wip counter.

Parameters

Returns:int

the current value after adding m

produced	back to summary
public long produced(long n)

requested	back to summary
public long requested()