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 ClassesModifier and TypeClassDescription(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) Throwable
(package private) ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode
<T> (package private) final int
(package private) final long
(package private) final Scheduler
(package private) int
(package private) ReplaySubject.ReplaySizeAndTimeBoundBuffer.TimedNode
<T> -
Constructor Summary
ConstructorsConstructorDescriptionReplaySizeAndTimeBoundBuffer
(int limit, long maxAgeMillis, Scheduler scheduler) -
Method Summary
-
Field Details
-
limit
final int limit -
maxAgeMillis
final long maxAgeMillis -
scheduler
-
head
-
tail
-
size
int size -
done
volatile boolean done -
error
Throwable error
-
-
Constructor Details
-
ReplaySizeAndTimeBoundBuffer
-
-
Method Details
-
next
- Specified by:
next
in interfaceReplaySubject.ReplayBuffer<T>
-
error
- 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
- Specified by:
drain
in interfaceReplaySubject.ReplayBuffer<T>
-
isComplete
public boolean isComplete()- Specified by:
isComplete
in interfaceReplaySubject.ReplayBuffer<T>
-
error
- Specified by:
error
in interfaceReplaySubject.ReplayBuffer<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
- Specified by:
toArray
in interfaceReplaySubject.ReplayBuffer<T>
-