io.reactivex.rxjava3.internal.util

public Interface ObservableQueueDrain<T, U>

Known Direct Implementers: io.reactivex.rxjava3.internal.observers.QueueDrainObserver
Imports: io.reactivex.rxjava3.core.Observer

Method Summary

Modifier and Type	Method and Description
public void	accept(Observer<? super U> the subscriber to deliver values to a, T the value to deliver 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 wip value after adding the value leave(int the value to add m) Adds m to the wip counter.

Method Detail

accept

back to summary

public void accept(Observer<? super U> a, T v)

Accept the value and return true if forwarded.

Parameters

a:Observer<? super U>: the subscriber to deliver values to
v:T: the value to deliver

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 wip value after adding the value