class ReplayProcessor extends FlowableProcessor<T> {

    @Override
    public boolean hasSubscribers() {
        return subscribers.get().length != 0;
    }

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

}