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 java.lang.Object implements ReplayProcessor.ReplayBuffer<T>
-
-
Constructor Summary
Constructors Constructor Description UnboundedReplayBuffer(int capacityHint)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
complete()
void
error(java.lang.Throwable ex)
java.lang.Throwable
getError()
T
getValue()
T[]
getValues(T[] array)
boolean
isDone()
void
next(T value)
void
replay(ReplayProcessor.ReplaySubscription<T> rs)
int
size()
void
trimHead()
Make sure an old inaccessible head value is released in a bounded buffer.
-
-
-
Field Detail
-
buffer
final java.util.List<T> buffer
-
error
java.lang.Throwable error
-
done
volatile boolean done
-
size
volatile int size
-
-
Method Detail
-
next
public void next(T value)
- Specified by:
next
in interfaceReplayProcessor.ReplayBuffer<T>
-
error
public void error(java.lang.Throwable ex)
- 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
@Nullable public T getValue()
- Specified by:
getValue
in interfaceReplayProcessor.ReplayBuffer<T>
-
getValues
public T[] getValues(T[] array)
- Specified by:
getValues
in interfaceReplayProcessor.ReplayBuffer<T>
-
replay
public void replay(ReplayProcessor.ReplaySubscription<T> rs)
- 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
public java.lang.Throwable getError()
- Specified by:
getError
in interfaceReplayProcessor.ReplayBuffer<T>
-
-