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 java.lang.Object implements ReplaySubject.ReplayBuffer<T>
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
ReplaySubject.ReplaySizeBoundBuffer.Node<T>
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
done
(package private) java.lang.Throwable
error
(package private) ReplaySubject.ReplaySizeBoundBuffer.Node<T>
head
(package private) int
limit
(package private) int
size
(package private) ReplaySubject.ReplaySizeBoundBuffer.Node<T>
tail
-
Constructor Summary
Constructors Constructor Description ReplaySizeBoundBuffer(int limit)
-
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)
boolean
isComplete()
boolean
isEmpty()
T
last()
void
next(T value)
int
size()
T[]
toArray(T[] a)
-
-
-
Field Detail
-
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
java.lang.Throwable error
-
-
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>
-
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>
-
-