Package rx.subjects

Class ReplaySubject.ReplaySizeAndTimeBoundBuffer<T>

java.lang.Object

rx.subjects.ReplaySubject.ReplaySizeAndTimeBoundBuffer<T>

All Implemented Interfaces:

ReplaySubject.ReplayBuffer<T>

Enclosing class:

ReplaySubject<T>

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

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	done
(package private) Throwable	error
(package private) ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode<T>	head
(package private) final int	limit
(package private) final long	maxAgeMillis
(package private) final Scheduler	scheduler
(package private) int	size
(package private) ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode<T>	tail

Constructor Summary

Constructors

Constructor	Description
ReplaySizeAndTimeBoundBuffer(int limit, long maxAgeMillis, Scheduler scheduler)

Method Summary

Modifier and Type	Method	Description
void	complete()
void	drain(ReplaySubject.ReplayProducer<T> rp)
Throwable	error()
void	error(Throwable ex)
(package private) void	evictFinal()
boolean	isComplete()
boolean	isEmpty()
T	last()
(package private) ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode<T>	latestHead()
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

maxAgeMillis

final long maxAgeMillis

scheduler

final Scheduler scheduler

head

volatile ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode<T> head

tail

ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode<T> tail

size

int size

done

volatile boolean done

error

Throwable error

Constructor Details

ReplaySizeAndTimeBoundBuffer

public ReplaySizeAndTimeBoundBuffer(int limit,
 long maxAgeMillis,
 Scheduler scheduler)

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>

evictFinal

void evictFinal()

latestHead

ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode<T> latestHead()

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>