Package io.reactivex.rxjava3.processors
Class ReplayProcessor.UnboundedReplayBuffer<T>
java.lang.Object
io.reactivex.rxjava3.processors.ReplayProcessor.UnboundedReplayBuffer<T>
- All Implemented Interfaces:
ReplayProcessor.ReplayBuffer<T>
- Enclosing class:
ReplayProcessor<T>
static final class ReplayProcessor.UnboundedReplayBuffer<T>
extends Object
implements ReplayProcessor.ReplayBuffer<T>
-
Field Details
-
buffer
-
error
Throwable error -
done
volatile boolean done -
size
volatile int size
-
-
Constructor Details
-
UnboundedReplayBuffer
UnboundedReplayBuffer(int capacityHint)
-
-
Method Details
-
next
- Specified by:
next
in interfaceReplayProcessor.ReplayBuffer<T>
-
error
- Specified by:
error
in interfaceReplayProcessor.ReplayBuffer<T>
-
complete
public void complete()- Specified by:
complete
in interfaceReplayProcessor.ReplayBuffer<T>
-
trimHead
public void trimHead()Description copied from interface:ReplayProcessor.ReplayBuffer
Make sure an old inaccessible head value is released in a bounded buffer.- Specified by:
trimHead
in interfaceReplayProcessor.ReplayBuffer<T>
-
getValue
- Specified by:
getValue
in interfaceReplayProcessor.ReplayBuffer<T>
-
getValues
- Specified by:
getValues
in interfaceReplayProcessor.ReplayBuffer<T>
-
replay
- Specified by:
replay
in interfaceReplayProcessor.ReplayBuffer<T>
-
size
public int size()- Specified by:
size
in interfaceReplayProcessor.ReplayBuffer<T>
-
isDone
public boolean isDone()- Specified by:
isDone
in interfaceReplayProcessor.ReplayBuffer<T>
-
getError
- Specified by:
getError
in interfaceReplayProcessor.ReplayBuffer<T>
-