T
- the value type of the chainpublic final class OnSubscribeAutoConnect<T> extends AtomicInteger implements Observable.OnSubscribe<T>
Constructor and Description |
---|
OnSubscribeAutoConnect(ConnectableObservable<? extends T> source,
int numberOfSubscribers,
Action1<? super Subscription> connection) |
Modifier and Type | Method and Description |
---|---|
void |
call(Subscriber<? super T> child) |
accumulateAndGet, addAndGet, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, incrementAndGet, intValue, lazySet, longValue, set, toString, updateAndGet, weakCompareAndSet
byteValue, shortValue
public OnSubscribeAutoConnect(ConnectableObservable<? extends T> source, int numberOfSubscribers, Action1<? super Subscription> connection)
public void call(Subscriber<? super T> child)
call
in interface Action1<Subscriber<? super T>>
Copyright © 2017. All rights reserved.