Class OperatorMulticast<T,​R>

  • Type Parameters:
    T - the source value type
    R - the result value type

    public final class OperatorMulticast<T,​R>
    extends ConnectableObservable<R>
    Shares a single subscription to a source through a Subject.
    • Field Detail

      • guard

        final java.lang.Object guard
      • subjectFactory

        final Func0<? extends Subject<? super T,​? extends R>> subjectFactory
      • connectedSubject

        final java.util.concurrent.atomic.AtomicReference<Subject<? super T,​? extends R>> connectedSubject
      • waitingForConnect

        final java.util.List<Subscriber<? super R>> waitingForConnect
      • subscription

        Subscriber<T> subscription
        Guarded by guard.
    • Constructor Detail

      • OperatorMulticast

        public OperatorMulticast​(Observable<? extends T> source,
                                 Func0<? extends Subject<? super T,​? extends R>> subjectFactory)
      • OperatorMulticast

        private OperatorMulticast​(java.lang.Object guard,
                                  java.util.concurrent.atomic.AtomicReference<Subject<? super T,​? extends R>> connectedSubject,
                                  java.util.List<Subscriber<? super R>> waitingForConnect,
                                  Observable<? extends T> source,
                                  Func0<? extends Subject<? super T,​? extends R>> subjectFactory)