Package rx.internal.operators

Class OnSubscribeDetach<T>

java.lang.Object

rx.internal.operators.OnSubscribeDetach<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

Action, Action1<Subscriber<? super T>>, Function, Observable.OnSubscribe<T>

public final class OnSubscribeDetach<T>
extends Object
implements Observable.OnSubscribe<T>

Nulls out references to upstream data structures when the source terminates or the child unsubscribes.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	OnSubscribeDetach.DetachProducer<T>	Callbacks from the child Subscriber.
(package private) static final class	OnSubscribeDetach.DetachSubscriber<T>	The parent subscriber that forwards events and cleans up on a terminal state.
(package private) static enum	OnSubscribeDetach.TerminatedProducer	Singleton instance via enum.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Observable<T>	source

Constructor Summary

Constructors

Constructor	Description
OnSubscribeDetach(Observable<T> source)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

source

final Observable<T> source

Constructor Details

OnSubscribeDetach

public OnSubscribeDetach(Observable<T> source)

Method Details

call

public void call(Subscriber<? super T> t)

Specified by:

call in interface Action1<T>