Method Detail

• getSpscInstance

   static RxRingBuffer getSpscInstance()

• getSpmcInstance

   static RxRingBuffer getSpmcInstance()

• release

   synchronized void release()

• unsubscribe

   void unsubscribe()

  Stops the receipt of notifications on the Subscriber that was registered when this Subscriptionwas received.

  This allows deregistering an Subscriber before it has finished receiving all events (i.e. beforeonCompleted is called).

• onNext

   void onNext(Object o)

  Parameters:

  o - the value to buffer

• onCompleted

   void onCompleted()

• onError

   void onError(Throwable t)

• available

   int available()

• capacity

   int capacity()

• count

   int count()

• isEmpty

   boolean isEmpty()

• poll

   Object poll()

• peek

   Object peek()

• isCompleted

   boolean isCompleted(Object o)

• isError

   boolean isError(Object o)

• getValue

   Object getValue(Object o)

• accept

   boolean accept(Object o, Observer child)

• asError

   Throwable asError(Object o)

• isUnsubscribed

   boolean isUnsubscribed()

  Indicates whether this {@code Subscription} is currently unsubscribed.