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 java.lang.Object
implements ReplaySubject.ReplayBuffer<T>

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	done
(package private) java.lang.Throwable	error
(package private) ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode<T>	head
(package private) int	limit
(package private) long	maxAgeMillis
(package private) 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)
java.lang.Throwable	error()
void	error(java.lang.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 Detail

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

java.lang.Throwable error

Constructor Detail

ReplaySizeAndTimeBoundBuffer

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

Method Detail

next

public void next(T value)

Specified by:

next in interface ReplaySubject.ReplayBuffer<T>

error

public void error(java.lang.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 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>