Packages that use Subject

• Uses of Subject in rx.internal.operators

  Subclasses of in

  Modifier and Type	Class and Description
  class	BufferUntilSubscriber<T> A solution to the "time gap" problem that occurs with groupBy and pivot.
  static class	OperatorReplay.SubjectWrapper<T> A subject that wraps another subject.

  Fields in declared as

  Modifier and Type	Field and Description
  protected Subject<? super T,? extends T>	OnSubscribeCache.cache

  Methods in that return

  Modifier and Type	Method and Description
  static <T> Subject<T,T>	OperatorReplay.createScheduledSubject(Subject<T,T> subject, Scheduler scheduler) Creates a subject whose client observers will observe events propagated through the given wrapped subject.

  Methods in with parameters of type

  Modifier and Type	Method and Description
  static <T> Subject<T,T>	OperatorReplay.createScheduledSubject(Subject<T,T> subject, Scheduler scheduler) Creates a subject whose client observers will observe events propagated through the given wrapped subject.

  Constructors in with parameters of type

  Constructor and Description
  	SubjectWrapper(Observable.OnSubscribe<T> func, Subject<T,T> subject)

  Constructor parameters in rx.internal.operators with type arguments of type Subject

  Constructor and Description
  	OnSubscribeMulticastSelector(Observable<? extends TInput> source, Func0<? extends Subject<? super TInput,? extends TIntermediate>> subjectFactory, Func1<? super Observable<TIntermediate>,? extends Observable<TResult>> resultSelector)
  	OperatorMulticast(Observable<? extends T> source, Func0<? extends Subject<? super T,? extends R>> subjectFactory)

• Uses of Subject in rx.subjects

  Subclasses of in

  Modifier and Type	Class and Description
  class	AsyncSubject<T> Subject that publishes only the last item observed to each Observer that has subscribed, when the source Observable completes.
  class	BehaviorSubject<T> Subject that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.
  class	PublishSubject<T> Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.
  class	ReplaySubject<T> Subject that buffers all items it observes and replays them to any Observer that subscribes.
  class	SerializedSubject<T,R> Wraps a Subject so that it is safe to call its various on methods from different threads.
  class	TestSubject<T> A variety of Subject that is useful for testing purposes.

  Constructors in rx.subjects with parameters of type Subject

  Constructor and Description
  	SerializedSubject(Subject<T,R> actual)