class MultiObserveOn implements Multi<T> {

    @Override
    public void subscribe(Flow.Subscriber<? super T> subscriber) {
        source.subscribe(new ObserveOnSubscriber<>(subscriber, executor, bufferSize, delayError));
    }

      MultiObserveOn(Multi<T> source, Executor executor, int bufferSize, boolean delayError);

}