Package rx.subjects
Class ReplaySubject.ReplayUnboundedBuffer<T>
java.lang.Object
rx.subjects.ReplaySubject.ReplayUnboundedBuffer<T>
- Type Parameters:
T
- the value type
- All Implemented Interfaces:
ReplaySubject.ReplayBuffer<T>
- Enclosing class:
ReplaySubject<T>
static final class ReplaySubject.ReplayUnboundedBuffer<T>
extends Object
implements ReplaySubject.ReplayBuffer<T>
An unbounded ReplayBuffer implementation that uses linked-arrays
to avoid copy-on-grow situation with ArrayList.
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
Constructor Details
-
ReplayUnboundedBuffer
public ReplayUnboundedBuffer(int capacity)
-
-
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>
-
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>
-