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
All Methods Instance Methods Concrete Methods 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)
-
-
-
Field Detail
-
limit
final int limit
-
maxAgeMillis
final long maxAgeMillis
-
scheduler
final Scheduler scheduler
-
head
volatile ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode<T> head
-
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 interfaceReplaySubject.ReplayBuffer<T>
-
error
public void error(java.lang.Throwable ex)
- Specified by:
error
in interfaceReplaySubject.ReplayBuffer<T>
-
complete
public void complete()
- Specified by:
complete
in interfaceReplaySubject.ReplayBuffer<T>
-
evictFinal
void evictFinal()
-
latestHead
ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode<T> latestHead()
-
drain
public void drain(ReplaySubject.ReplayProducer<T> rp)
- Specified by:
drain
in interfaceReplaySubject.ReplayBuffer<T>
-
isComplete
public boolean isComplete()
- Specified by:
isComplete
in interfaceReplaySubject.ReplayBuffer<T>
-
error
public java.lang.Throwable error()
- Specified by:
error
in interfaceReplaySubject.ReplayBuffer<T>
-
last
public T last()
- Specified by:
last
in interfaceReplaySubject.ReplayBuffer<T>
-
size
public int size()
- Specified by:
size
in interfaceReplaySubject.ReplayBuffer<T>
-
isEmpty
public boolean isEmpty()
- Specified by:
isEmpty
in interfaceReplaySubject.ReplayBuffer<T>
-
toArray
public T[] toArray(T[] a)
- Specified by:
toArray
in interfaceReplaySubject.ReplayBuffer<T>
-
-