Package rx.internal.operators

Class OperatorDoOnUnsubscribe<T>

java.lang.Object

rx.internal.operators.OperatorDoOnUnsubscribe<T>

Type Parameters:

T - The type of the elements in the Observable that this operator modifies

All Implemented Interfaces:

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

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

This operator modifies an Observable so a given action is invoked when the Observable is unsubscribed.

Field Summary

Fields

Modifier and Type	Field	Description
private final Action0	unsubscribe

Constructor Summary

Constructors

Constructor	Description
OperatorDoOnUnsubscribe(Action0 unsubscribe)	Constructs an instance of the operator with the callback that gets invoked when the modified Observable is unsubscribed

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

unsubscribe

private final Action0 unsubscribe

Constructor Details

OperatorDoOnUnsubscribe

public OperatorDoOnUnsubscribe(Action0 unsubscribe)

Constructs an instance of the operator with the callback that gets invoked when the modified Observable is unsubscribed

Parameters:

unsubscribe - The action that gets invoked when the modified Observable is unsubscribed

Method Details

call

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

Specified by:

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