Package io.reactivex.rxjava3.processors
Class ReplayProcessor.SizeAndTimeBoundReplayBuffer<T>
java.lang.Object
io.reactivex.rxjava3.processors.ReplayProcessor.SizeAndTimeBoundReplayBuffer<T>
- All Implemented Interfaces:
ReplayProcessor.ReplayBuffer<T>
- Enclosing class:
ReplayProcessor<T>
static final class ReplayProcessor.SizeAndTimeBoundReplayBuffer<T>
extends Object
implements ReplayProcessor.ReplayBuffer<T>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) Throwable
(package private) ReplayProcessor.TimedNode
<T> (package private) final long
(package private) final int
(package private) final Scheduler
(package private) int
(package private) ReplayProcessor.TimedNode
<T> (package private) final TimeUnit
-
Constructor Summary
ConstructorsConstructorDescriptionSizeAndTimeBoundReplayBuffer
(int maxSize, long maxAge, TimeUnit unit, Scheduler scheduler) -
Method Summary
Modifier and TypeMethodDescriptionvoid
complete()
void
getError()
(package private) ReplayProcessor.TimedNode
<T> getHead()
getValue()
T[]
boolean
isDone()
void
void
int
size()
(package private) int
(package private) void
trim()
(package private) void
void
trimHead()
Make sure an old inaccessible head value is released in a bounded buffer.
-
Field Details
-
maxSize
final int maxSize -
maxAge
final long maxAge -
unit
-
scheduler
-
size
int size -
head
-
tail
ReplayProcessor.TimedNode<T> tail -
error
Throwable error -
done
volatile boolean done
-
-
Constructor Details
-
SizeAndTimeBoundReplayBuffer
-
-
Method Details
-
trim
void trim() -
trimFinal
void trimFinal() -
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>
-
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>
-
getValue
- Specified by:
getValue
in interfaceReplayProcessor.ReplayBuffer<T>
-
getValues
- Specified by:
getValues
in interfaceReplayProcessor.ReplayBuffer<T>
-
getHead
ReplayProcessor.TimedNode<T> getHead() -
replay
- Specified by:
replay
in interfaceReplayProcessor.ReplayBuffer<T>
-
size
public int size()- Specified by:
size
in interfaceReplayProcessor.ReplayBuffer<T>
-
size
-
getError
- Specified by:
getError
in interfaceReplayProcessor.ReplayBuffer<T>
-
isDone
public boolean isDone()- Specified by:
isDone
in interfaceReplayProcessor.ReplayBuffer<T>
-