com.github.davidmoten.rx.internal.operators

Class OperatorMaterializeLite<T>

java.lang.Object

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

All Implemented Interfaces:

rx.functions.Func1<rx.Subscriber<? super Object>,rx.Subscriber<? super T>>, rx.functions.Function, rx.Observable.Operator<Object,T>

public final class OperatorMaterializeLite<T>
extends Object
implements rx.Observable.Operator<Object,T>

Turns all of the notifications from an Observable into onNext emissions, and marks them with their original notification types within NotificationLite objects.

See here for the Microsoft Rx equivalent.

Method Summary

Modifier and Type	Method and Description
rx.Subscriber<? super T>	call(rx.Subscriber<? super Object> child)
static <T> OperatorMaterializeLite<T>	instance()

Methods inherited from class java.lang.Object

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

Method Detail

instance

public static <T> OperatorMaterializeLite<T> instance()

Returns:

a singleton instance of this stateless operator.

call

public rx.Subscriber<? super T> call(rx.Subscriber<? super Object> child)

Specified by:

call in interface rx.functions.Func1<rx.Subscriber<? super Object>,rx.Subscriber<? super T>>