com.github.davidmoten.rx.operators

Class OperatorUnsubscribeEagerly<T>

java.lang.Object

com.github.davidmoten.rx.operators.OperatorUnsubscribeEagerly<T>

All Implemented Interfaces:

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

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OperatorUnsubscribeEagerly.Singleton

Constructor Summary

Constructors

Constructor and Description
OperatorUnsubscribeEagerly()

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorUnsubscribeEagerly

public OperatorUnsubscribeEagerly()

Method Detail

call

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

Specified by:

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