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>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) java.util.List<T>	buffer
(package private) boolean	done
(package private) java.lang.Throwable	error
(package private) int	size

Constructor Summary

Constructors

Constructor	Description
UnboundedReplayBuffer(int capacityHint)

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

buffer

final java.util.List<T> buffer

error

java.lang.Throwable error

done

volatile boolean done

size

volatile int size

Constructor Detail

UnboundedReplayBuffer

UnboundedReplayBuffer(int capacityHint)

Method Detail

next

public void next(T value)

Specified by:

next in interface ReplayProcessor.ReplayBuffer<T>

error

public void error(java.lang.Throwable ex)

Specified by:

error in interface ReplayProcessor.ReplayBuffer<T>

complete

public void complete()

Specified by:

complete in interface ReplayProcessor.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 interface ReplayProcessor.ReplayBuffer<T>

getValue

@Nullable
public T getValue()

Specified by:

getValue in interface ReplayProcessor.ReplayBuffer<T>

getValues

public T[] getValues(T[] array)

Specified by:

getValues in interface ReplayProcessor.ReplayBuffer<T>

replay

public void replay(ReplayProcessor.ReplaySubscription<T> rs)

Specified by:

replay in interface ReplayProcessor.ReplayBuffer<T>

size

public int size()

Specified by:

size in interface ReplayProcessor.ReplayBuffer<T>

isDone

public boolean isDone()

Specified by:

isDone in interface ReplayProcessor.ReplayBuffer<T>

getError

public java.lang.Throwable getError()

Specified by:

getError in interface ReplayProcessor.ReplayBuffer<T>