Package 

Class PublishSubject

  • All Implemented Interfaces:
    com.tds.common.reactor.Observer 
    
public final class PublishSubject<T>
extends Subject<T, T>

    • Method Summary

      Modifier and Type Method Description
      static <T> PublishSubject<T> create() Creates and returns a new {@code PublishSubject}.
      void onNext(T v)
      void onError(Throwable e)
      void onCompleted()
      boolean hasObservers() Indicates whether the Subject has Observers subscribed to it.
      boolean hasThrowable() Check if the Subject has terminated with an exception.
      boolean hasCompleted() Check if the Subject has terminated normally.
      Throwable getThrowable() Returns the Throwable that terminated the Subject.

      • Methods inherited from class com.tds.common.reactor.subjects.Subject

        toSerialized

      • Methods inherited from class com.tds.common.reactor.Observable

        create, debounce, doOnError, empty, error, filter, flatMap, from, from, just, just, just, just, just, lift, map, merge, observeOn, observeOn, observeOn, onErrorResumeNext, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeOn, timeout, timeout, toList, unsafeCreate, unsafeSubscribe

      • Methods inherited from class com.tds.common.reactor.Observer

        onNext

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait