Package io.reactivex.rxjava3.processors
Class ReplayProcessor.SizeBoundReplayBuffer<T>
java.lang.Object
io.reactivex.rxjava3.processors.ReplayProcessor.SizeBoundReplayBuffer<T>
- All Implemented Interfaces:
ReplayProcessor.ReplayBuffer<T>
- Enclosing class:
ReplayProcessor<T>
static final class ReplayProcessor.SizeBoundReplayBuffer<@NonNull T>
extends Object
implements ReplayProcessor.ReplayBuffer<T>
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
maxSize
final int maxSize -
size
int size -
head
-
tail
ReplayProcessor.Node<T> tail -
error
Throwable error -
done
volatile boolean done
-
-
Constructor Details
-
SizeBoundReplayBuffer
SizeBoundReplayBuffer(int maxSize)
-
-
Method Details
-
trim
void trim() -
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>
-
isDone
public boolean isDone()- Specified by:
isDone
in interfaceReplayProcessor.ReplayBuffer<T>
-
getError
- Specified by:
getError
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>
-