class BehaviorProcessor extends FlowableProcessor<T> {

    @Override
    public void onSubscribe(Subscription s) {
        if (terminalEvent.get() != null) {
            s.cancel();
            return;
        }
        s.request(Long.MAX_VALUE);
    }

    @SuppressWarnings("unchecked")  BehaviorProcessor();
      BehaviorProcessor(T defaultValue);

}