Package rx.internal.operators

Class OperatorDoOnSubscribe<T>

java.lang.Object

rx.internal.operators.OperatorDoOnSubscribe<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 OperatorDoOnSubscribe<T>
extends Object
implements Observable.Operator<T,T>

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

Field Summary

Fields

Modifier and Type	Field	Description
private final Action0	subscribe

Constructor Summary

Constructors

Constructor	Description
OperatorDoOnSubscribe(Action0 subscribe)	Constructs an instance of the operator with the callback that gets invoked when the modified Observable is subscribed

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

subscribe

private final Action0 subscribe

Constructor Details

OperatorDoOnSubscribe

public OperatorDoOnSubscribe(Action0 subscribe)

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

Parameters:

subscribe - the action that gets invoked when the modified Observable is subscribed

Method Details

call

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

Specified by:

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