com.github.davidmoten.rx.internal.operators

Class OnSubscribeFromQueue<T>

java.lang.Object

rx.observables.SyncOnSubscribe<Queue<T>,T>

com.github.davidmoten.rx.internal.operators.OnSubscribeFromQueue<T>

All Implemented Interfaces:

rx.functions.Action, rx.functions.Action1<rx.Subscriber<? super T>>, rx.functions.Function, rx.Observable.OnSubscribe<T>

public class OnSubscribeFromQueue<T>
extends rx.observables.SyncOnSubscribe<Queue<T>,T>

Constructor Summary

Constructors

Constructor and Description
OnSubscribeFromQueue(Queue<T> queue)

Method Summary

Modifier and Type	Method and Description
protected Queue<T>	generateState()
protected Queue<T>	next(Queue<T> queue, rx.Observer<? super T> observer)

Methods inherited from class rx.observables.SyncOnSubscribe

call, createSingleState, createSingleState, createStateful, createStateful, createStateless, createStateless, onUnsubscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

OnSubscribeFromQueue

public OnSubscribeFromQueue(Queue<T> queue)

Method Detail

generateState

protected Queue<T> generateState()

Specified by:

generateState in class rx.observables.SyncOnSubscribe<Queue<T>,T>

next

protected Queue<T> next(Queue<T> queue,
                        rx.Observer<? super T> observer)

Specified by:

next in class rx.observables.SyncOnSubscribe<Queue<T>,T>