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);
	}
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.