Package rx.internal.operators

Class OperatorDematerialize<T>

java.lang.Object

rx.internal.operators.OperatorDematerialize<T>

Type Parameters:

T - the wrapped value type

All Implemented Interfaces:

Func1<Subscriber<? super T>,Subscriber<? super Notification<T>>>, Function, Observable.Operator<T,Notification<T>>

public final class OperatorDematerialize<T>
extends Object
implements Observable.Operator<T,Notification<T>>

Reverses the effect of OperatorMaterialize by transforming the Notification objects emitted by a source Observable into the items or notifications they represent.

See here for the Microsoft Rx equivalent.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	OperatorDematerialize.Holder	Lazy initialization via inner-class holder.

Constructor Summary

Constructors

Constructor	Description
OperatorDematerialize()

Method Summary

Modifier and Type	Method	Description
Subscriber<? super Notification<T>>	call(Subscriber<? super T> child)
static OperatorDematerialize	instance()

Methods inherited from class java.lang.Object

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

Constructor Details

OperatorDematerialize

OperatorDematerialize()

Method Details

instance

public static OperatorDematerialize instance()

Returns:

a singleton instance of this stateless operator.

call

public Subscriber<? super Notification<T>> call(Subscriber<? super T> child)

Specified by:

call in interface Func1<Subscriber<? super T>,Subscriber<? super Notification<T>>>