Package rx.subjects

Class ReplaySubject.ReplaySizeBoundBuffer<T>

java.lang.Object

rx.subjects.ReplaySubject.ReplaySizeBoundBuffer<T>

All Implemented Interfaces:

ReplaySubject.ReplayBuffer<T>

Enclosing class:

ReplaySubject<T>

static final class ReplaySubject.ReplaySizeBoundBuffer<T>
extends Object
implements ReplaySubject.ReplayBuffer<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	ReplaySubject.ReplaySizeBoundBuffer.Node<T>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	done
(package private) Throwable	error
(package private) ReplaySubject.ReplaySizeBoundBuffer.Node<T>	head
(package private) final int	limit
(package private) int	size
(package private) ReplaySubject.ReplaySizeBoundBuffer.Node<T>	tail

Constructor Summary

Constructors

Constructor	Description
ReplaySizeBoundBuffer(int limit)

Method Summary

Modifier and Type	Method	Description
void	complete()
void	drain(ReplaySubject.ReplayProducer<T> rp)
Throwable	error()
void	error(Throwable ex)
boolean	isComplete()
boolean	isEmpty()
T	last()
void	next(T value)
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 Details

limit

final int limit

head

volatile ReplaySubject.ReplaySizeBoundBuffer.Node<T> head

tail

ReplaySubject.ReplaySizeBoundBuffer.Node<T> tail

size

int size

done

volatile boolean done

error

Throwable error

Constructor Details

ReplaySizeBoundBuffer

public ReplaySizeBoundBuffer(int limit)

Method Details

next

public void next(T value)

Specified by:

next in interface ReplaySubject.ReplayBuffer<T>

error

public void error(Throwable ex)

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 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>