Class OnSubscribeUsing<T,Resource>

java.lang.Object
rx.internal.operators.OnSubscribeUsing<T,Resource>
Type Parameters:
T - the output value type
Resource - the resource type
All Implemented Interfaces:
Action, Action1<Subscriber<? super T>>, Function, Observable.OnSubscribe<T>

public final class OnSubscribeUsing<T,Resource> extends Object implements Observable.OnSubscribe<T>
Constructs an observable sequence that depends on a resource object.
  • Field Details

    • resourceFactory

      private final Func0<Resource> resourceFactory
    • observableFactory

      private final Func1<? super Resource,? extends Observable<? extends T>> observableFactory
    • dispose

      private final Action1<? super Resource> dispose
    • disposeEagerly

      private final boolean disposeEagerly
  • Constructor Details

  • Method Details