src/main/java/io/reactivex/internal/operators/flowable/FlowableBlockingSubscribe.java
public static <T> void subscribe(Publisher<? extends T> o, final Consumer<? super T> onNext,
        final Consumer<? super Throwable> onError, final Action onComplete, int bufferSize) {
        ObjectHelper.requireNonNull(onNext, "onNext is null");
        ObjectHelper.requireNonNull(onError, "onError is null");
        ObjectHelper.requireNonNull(onComplete, "onComplete is null");
        ObjectHelper.verifyPositive(bufferSize, "number > 0 required");
        subscribe(o, new BoundedSubscriber<T>(onNext, onError, onComplete, Functions.boundedConsumer(bufferSize),
                bufferSize));
    }
public static <T> void subscribe(Publisher<? extends T> o, final Consumer<? super T> onNext,
        final Consumer<? super Throwable> onError, final Action onComplete, int bufferSize) {
        ObjectHelper.requireNonNull(onNext, "onNext is null");
        ObjectHelper.requireNonNull(onError, "onError is null");
        ObjectHelper.requireNonNull(onComplete, "onComplete is null");
        ObjectHelper.verifyPositive(bufferSize, "number > 0 required");
        subscribe(o, new BoundedSubscriber<T>(onNext, onError, onComplete, Functions.boundedConsumer(bufferSize),
                bufferSize));
    }
public static < T > void subscribe ( Publisher < ? extends T > o , final Consumer < ? super T > onNext , final Consumer < ? super Throwable > onError , final Action onComplete , int bufferSize ) { ObjectHelper . requireNonNull ( onNext , "onNext is null" ) ; ObjectHelper . requireNonNull ( onError , "onError is null" ) ; ObjectHelper . requireNonNull ( onComplete , "onComplete is null" ) ; ObjectHelper . verifyPositive ( bufferSize , "number > 0 required" ) ; subscribe ( o , new BoundedSubscriber < T > ( onNext , onError , onComplete , Functions . boundedConsumer ( bufferSize ) , bufferSize ) ) ; }
Subscribes to the source and calls the given actions on the current thread.
@param o the source publisher
@param onNext the callback action for each source value
@param onError the callback action for an error event
@param onComplete the callback action for the completion event.
@param bufferSize the number of elements to prefetch from the source Publisher
@param <T> the value type
Subscribes to the source and calls the given actions on the current thread .