T
- the value type emittedpublic final class OnSubscribeFromCallable<T> extends Object implements Observable.OnSubscribe<T>
Pass fromCallable
a function, and fromCallable
will call this function to emit result of invocation
afresh each time a new Observer subscribes.
Constructor and Description |
---|
OnSubscribeFromCallable(Callable<? extends T> resultFactory) |
public void call(Subscriber<? super T> subscriber)
call
in interface Action1<Subscriber<? super T>>
Copyright © 2018. All rights reserved.