class ReplayProcessor extends FlowableProcessor<T> {

    @CheckReturnValue
    @NonNull
    public static <T> ReplayProcessor<T> createWithSize(int maxSize) {
        return new ReplayProcessor<T>(new SizeBoundReplayBuffer<T>(maxSize));
    }

    @SuppressWarnings("unchecked")  ReplayProcessor(ReplayBuffer<T> buffer);

}