reactor-core/src/main/java/reactor/core/publisher/ReplayProcessor.java
public static <E> ReplayProcessor<E> create(int historySize, boolean unbounded) {
		FluxReplay.ReplayBuffer<E> buffer;
		if (unbounded) {
			buffer = new FluxReplay.UnboundedReplayBuffer<>(historySize);
		}
		else {
			buffer = new FluxReplay.SizeBoundReplayBuffer<>(historySize);
		}
		return new ReplayProcessor<>(buffer);
	}
public static <E> ReplayProcessor<E> create(int historySize, boolean unbounded) {
		FluxReplay.ReplayBuffer<E> buffer;
		if (unbounded) {
			buffer = new FluxReplay.UnboundedReplayBuffer<>(historySize);
		}
		else {
			buffer = new FluxReplay.SizeBoundReplayBuffer<>(historySize);
		}
		return new ReplayProcessor<>(buffer);
	}
public static < E > ReplayProcessor < E > create ( int historySize , boolean unbounded ) { FluxReplay . ReplayBuffer < E > buffer ; if ( unbounded ) { buffer = new FluxReplay . UnboundedReplayBuffer <> ( historySize ) ; } else { buffer = new FluxReplay . SizeBoundReplayBuffer <> ( historySize ) ; } return new ReplayProcessor <> ( buffer ) ; }
Create a new {@link ReplayProcessor} that either replay all the elements or a
limited amount of elements depending on the {@code unbounded} parameter.

@param historySize maximum items retained if bounded, or initial link size if unbounded
@param unbounded true if "unlimited" data store must be supplied
@param <E> the type of the pushed elements

@return a new {@link ReplayProcessor} that replays the whole history to each new
{@link Subscriber} if configured as unbounded, a limited history otherwise.
Create a new { @link ReplayProcessor } that either replay all the elements or a limited amount of elements depending on the { @code unbounded } parameter .