Package rx.subjects

Class ReplaySubject.ReplayUnboundedBuffer<T>

java.lang.Object

rx.subjects.ReplaySubject.ReplayUnboundedBuffer<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

ReplaySubject.ReplayBuffer<T>

Enclosing class:

ReplaySubject<T>

static final class ReplaySubject.ReplayUnboundedBuffer<T>
extends java.lang.Object
implements ReplaySubject.ReplayBuffer<T>

An unbounded ReplayBuffer implementation that uses linked-arrays to avoid copy-on-grow situation with ArrayList.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) int	capacity
(package private) boolean	done
(package private) java.lang.Throwable	error
(package private) java.lang.Object[]	head
(package private) int	size
(package private) java.lang.Object[]	tail
(package private) int	tailIndex

Constructor Summary

Constructors

Constructor	Description
ReplayUnboundedBuffer(int capacity)

Method Summary

Modifier and Type	Method	Description
void	complete()
void	drain(ReplaySubject.ReplayProducer<T> rp)
java.lang.Throwable	error()
void	error(java.lang.Throwable e)
boolean	isComplete()
boolean	isEmpty()
T	last()
void	next(T t)
int	size()
T[]	toArray(T[] a)

Methods inherited from class java.lang.Object

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

Field Detail

capacity

final int capacity

size

volatile int size

head

final java.lang.Object[] head

tail

java.lang.Object[] tail

tailIndex

int tailIndex

done

volatile boolean done

error

java.lang.Throwable error

Constructor Detail

ReplayUnboundedBuffer

public ReplayUnboundedBuffer(int capacity)

Method Detail

next

public void next(T t)

Specified by:

next in interface ReplaySubject.ReplayBuffer<T>

error

public void error(java.lang.Throwable e)

Specified by:

error in interface ReplaySubject.ReplayBuffer<T>

complete

public void complete()

Specified by:

complete in interface ReplaySubject.ReplayBuffer<T>

drain

public void drain(ReplaySubject.ReplayProducer<T> rp)

Specified by:

drain in interface ReplaySubject.ReplayBuffer<T>

isComplete

public boolean isComplete()

Specified by:

isComplete in interface ReplaySubject.ReplayBuffer<T>

error

public java.lang.Throwable error()

Specified by:

error in interface ReplaySubject.ReplayBuffer<T>

last

public T last()

Specified by:

last in interface ReplaySubject.ReplayBuffer<T>

size

public int size()

Specified by:

size in interface ReplaySubject.ReplayBuffer<T>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface ReplaySubject.ReplayBuffer<T>

toArray

public T[] toArray(T[] a)

Specified by:

toArray in interface ReplaySubject.ReplayBuffer<T>