Package rx.internal.operators
Class OnSubscribeAutoConnect<T>
java.lang.Object
rx.internal.operators.OnSubscribeAutoConnect<T>
- Type Parameters:
T
- the value type of the chain
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super T>>
,Function
,Observable.OnSubscribe<T>
Wraps a ConnectableObservable and calls its connect() method once
the specified number of Subscribers have subscribed.
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final AtomicInteger
(package private) final Action1
<? super Subscription> (package private) final int
(package private) final ConnectableObservable
<? extends T> -
Constructor Summary
ConstructorsConstructorDescriptionOnSubscribeAutoConnect
(ConnectableObservable<? extends T> source, int numberOfSubscribers, Action1<? super Subscription> connection) -
Method Summary
-
Field Details
-
source
-
numberOfSubscribers
final int numberOfSubscribers -
connection
-
clients
-
-
Constructor Details
-
OnSubscribeAutoConnect
public OnSubscribeAutoConnect(ConnectableObservable<? extends T> source, int numberOfSubscribers, Action1<? super Subscription> connection)
-
-
Method Details