Top Description Fields Constructors Methods

rx.internal.operators

public final Class OnSubscribeAutoConnect<T>

Class Inheritance

extends AtomicInteger
implements Observable.OnSubscribe<T>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
rx.internal.operators.OnSubscribeAutoConnect

All Implemented Interfaces

rx.Observable.OnSubscribe, rx.functions.Action1, rx.functions.Action, rx.functions.Function

Annotations

@SuppressWarnings:serial

Type Parameters

<T>: the value type of the chain

Imports

java.util.concurrent.atomic.AtomicInteger, rx.*, .Observable.OnSubscribe, rx.functions.Action1, rx.observables.ConnectableObservable, rx.observers.Subscribers

Wraps a ConnectableObservable and calls its connect() method once the specified number of Subscribers have subscribed.

Field Summary

Modifier and Type	Field and Description
pack-priv final Action1<? super Subscription>	connection
pack-priv final int	numberOfSubscribers
pack-priv final ConnectableObservable<? extends T>	source

Constructor Summary

Access	Constructor and Description
public	OnSubscribeAutoConnect(ConnectableObservable<? extends T> source, int numberOfSubscribers, Action1<? super Subscription> connection)

Method Summary

Modifier and Type	Method and Description
public void	call(Subscriber<? super T> child) Implements rx.functions.Action1.call.

Field Detail

connection	back to summary
pack-priv final Action1<? super Subscription> connection

numberOfSubscribers	back to summary
pack-priv final int numberOfSubscribers

source	back to summary
pack-priv final ConnectableObservable<? extends T> source

Constructor Detail

OnSubscribeAutoConnect	back to summary
public OnSubscribeAutoConnect(ConnectableObservable<? extends T> source, int numberOfSubscribers, Action1<? super Subscription> connection)

Method Detail

call

back to summary

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

Implements rx.functions.Action1.call.

Annotations

@Override