static <T> ReplayProcessor<T> createUnbounded() {
        return new ReplayProcessor<T>(new SizeBoundReplayBuffer<T>(Integer.MAX_VALUE));
    }
static <T> ReplayProcessor<T> createUnbounded() {
        return new ReplayProcessor<T>(new SizeBoundReplayBuffer<T>(Integer.MAX_VALUE));
    }
static < T > ReplayProcessor < T > createUnbounded ( ) { return new ReplayProcessor < T > ( new SizeBoundReplayBuffer < T > ( Integer . MAX_VALUE ) ) ; }
/* test
/ * test