RxRingBuffer

java.lang.Object
- rx.internal.util.RxRingBuffer

All Implemented Interfaces:

Subscription
```
public class RxRingBuffer
extends Object
implements Subscription
```
This assumes Spsc or Spmc usage. This means only a single producer calling the on* methods. This is the Rx contract of an Observer. Concurrent invocations of on* methods will not be thread-safe.

Field Summary

Fields

Modifier and Type	Field and Description
`static int`	`SIZE`
`Object`	`terminalState` We store the terminal state separately so it doesn't count against the size.

Method Summary

All Methods

Static Methods

Instance Methods

Concrete Methods
Modifier and Type	Method and Description
`boolean`	`accept(Object o, Observer child)`
`Throwable`	`asError(Object o)`
`int`	`available()`
`int`	`capacity()`
`int`	`count()`
`static RxRingBuffer`	`getSpmcInstance()`
`static RxRingBuffer`	`getSpscInstance()`
`Object`	`getValue(Object o)`
`boolean`	`isCompleted(Object o)`
`boolean`	`isEmpty()`
`boolean`	`isError(Object o)`
`boolean`	`isUnsubscribed()` Indicates whether this `Subscription` is currently unsubscribed.
`void`	`onCompleted()`
`void`	`onError(Throwable t)`
`void`	`onNext(Object o)`
`Object`	`peek()`
`Object`	`poll()`
`void`	`release()`
`void`	`unsubscribe()` Stops the receipt of notifications on the `Subscriber` that was registered when this Subscription was received.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - terminalState
```
public volatile Object terminalState
```
    We store the terminal state separately so it doesn't count against the size. We don't just +1 the size since some of the queues require sizes that are a power of 2. This is a subjective thing ... wanting to keep the size (ie 1024) the actual number of onNext that can be sent rather than something like 1023 onNext + 1 terminal event. It also simplifies checking that we have received only 1 terminal event, as we don't need to peek at the last item or retain a boolean flag.
  - SIZE
```
public static final int SIZE
```
- Method Detail
  - getSpscInstance
```
public static RxRingBuffer getSpscInstance()
```
  - getSpmcInstance
```
public static RxRingBuffer getSpmcInstance()
```
  - release
```
public void release()
```
  - unsubscribe
```
public void unsubscribe()
```
    Description copied from interface: Subscription
    
    Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.
    This allows unregistering an Subscriber before it has finished receiving all events (i.e. before onCompleted is called).
  - onNext
```
public void onNext(Object o)
            throws MissingBackpressureException
```
    Parameters:
    
    o -
    
    Throws:
    
    MissingBackpressureException - if more onNext are sent than have been requested
  - onCompleted
```
public void onCompleted()
```
  - onError
```
public void onError(Throwable t)
```
  - available
```
public int available()
```
  - capacity
```
public int capacity()
```
  - count
```
public int count()
```
  - isEmpty
```
public boolean isEmpty()
```
  - poll
```
public Object poll()
```
  - peek
```
public Object peek()
```
  - isCompleted
```
public boolean isCompleted(Object o)
```
  - isError
```
public boolean isError(Object o)
```
  - getValue
```
public Object getValue(Object o)
```
  - accept
```
public boolean accept(Object o,
                      Observer child)
```
  - asError
```
public Throwable asError(Object o)
```
  - isUnsubscribed
```
public boolean isUnsubscribed()
```
    Description copied from interface: Subscription
    
    Indicates whether this Subscription is currently unsubscribed.
    
    Specified by:
    
    isUnsubscribed in interface Subscription
    
    Returns:
    
    true if this Subscription is currently unsubscribed, false otherwise

Class RxRingBuffer

Field Summary

Fields

Method Summary

Methods inherited from class java.lang.Object

Field Detail

terminalState

SIZE

Method Detail

getSpscInstance

getSpmcInstance

release

unsubscribe

onNext

onCompleted

onError

available

capacity

count

isEmpty

poll

peek

isCompleted

isError

getValue

accept

asError

isUnsubscribed