public interface NbpOnSubscribe<T> extends Consumer<NbpSubscriber<? super T>> {

}

public interface NbpOperator<Downstream, Upstream> extends Function<NbpSubscriber<? super Downstream>, NbpSubscriber<? super Upstream>> {

}

public interface NbpSubscriber<T> {

void onSubscribe(Disposable d);

void onNext(T value);

void onError(Throwable e);

void onComplete();

}

public interface NbpTransformer<Upstream, Downstream> extends Function<NbpObservable<Upstream>, NbpObservable<Downstream>> {

}

/** An empty observable instance as there is no need to instantiate this more than once. */

static final NbpObservable<Object> EMPTY = create(new NbpOnSubscribe<Object>() {

@Override

public void accept(NbpSubscriber<? super Object> s) {

s.onSubscribe(EmptyDisposable.INSTANCE);

s.onComplete();

}

});

/** A never NbpObservable instance as there is no need to instantiate this more than once. */

static final NbpObservable<Object> NEVER = create(new NbpOnSubscribe<Object>() {

@Override

public void accept(NbpSubscriber<? super Object> s) {

s.onSubscribe(EmptyDisposable.INSTANCE);

}

});

static final Object OBJECT = new Object();

public static <T> NbpObservable<T> amb(Iterable<? extends NbpObservable<? extends T>> sources) {

Objects.requireNonNull(sources, "sources is null");

return create(new NbpOnSubscribeAmb<T>(null, sources));

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> amb(NbpObservable<? extends T>... sources) {

Objects.requireNonNull(sources, "sources is null");

int len = sources.length;

if (len == 0) {

return empty();

} else

if (len == 1) {

return (NbpObservable<T>)sources[0];

}

return create(new NbpOnSubscribeAmb<T>(sources, null));

}

/**

static int bufferSize() {

return Observable.bufferSize();

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T, R> NbpObservable<R> combineLatest(Function<? super Object[], ? extends R> combiner, boolean delayError, int bufferSize, NbpObservable<? extends T>... sources) {

return combineLatest(sources, combiner, delayError, bufferSize);

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T, R> NbpObservable<R> combineLatest(Iterable<? extends NbpObservable<? extends T>> sources, Function<? super Object[], ? extends R> combiner) {

return combineLatest(sources, combiner, false, bufferSize());

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T, R> NbpObservable<R> combineLatest(Iterable<? extends NbpObservable<? extends T>> sources, Function<? super Object[], ? extends R> combiner, boolean delayError) {

return combineLatest(sources, combiner, delayError, bufferSize());

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T, R> NbpObservable<R> combineLatest(Iterable<? extends NbpObservable<? extends T>> sources, Function<? super Object[], ? extends R> combiner, boolean delayError, int bufferSize) {

Objects.requireNonNull(sources, "sources is null");

Objects.requireNonNull(combiner, "combiner is null");

validateBufferSize(bufferSize);

// the queue holds a pair of values so we need to double the capacity

int s = bufferSize << 1;

return create(new NbpOnSubscribeCombineLatest<T, R>(null, sources, combiner, s, delayError));

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T, R> NbpObservable<R> combineLatest(NbpObservable<? extends T>[] sources, Function<? super Object[], ? extends R> combiner) {

return combineLatest(sources, combiner, false, bufferSize());

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T, R> NbpObservable<R> combineLatest(NbpObservable<? extends T>[] sources, Function<? super Object[], ? extends R> combiner, boolean delayError) {

return combineLatest(sources, combiner, delayError, bufferSize());

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T, R> NbpObservable<R> combineLatest(NbpObservable<? extends T>[] sources, Function<? super Object[], ? extends R> combiner, boolean delayError, int bufferSize) {

validateBufferSize(bufferSize);

Objects.requireNonNull(combiner, "combiner is null");

if (sources.length == 0) {

return empty();

}

// the queue holds a pair of values so we need to double the capacity

int s = bufferSize << 1;

return create(new NbpOnSubscribeCombineLatest<T, R>(sources, null, combiner, s, delayError));

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T1, T2, R> NbpObservable<R> combineLatest(

NbpObservable<? extends T1> p1, NbpObservable<? extends T2> p2,

BiFunction<? super T1, ? super T2, ? extends R> combiner) {

return combineLatest(Functions.toFunction(combiner), false, bufferSize(), p1, p2);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T1, T2, T3, R> NbpObservable<R> combineLatest(

NbpObservable<? extends T1> p1, NbpObservable<? extends T2> p2,

NbpObservable<? extends T3> p3,

Function3<? super T1, ? super T2, ? super T3, ? extends R> combiner) {

return combineLatest(Functions.toFunction(combiner), false, bufferSize(), p1, p2, p3);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T1, T2, T3, T4, R> NbpObservable<R> combineLatest(

NbpObservable<? extends T1> p1, NbpObservable<? extends T2> p2,

NbpObservable<? extends T3> p3, NbpObservable<? extends T4> p4,

Function4<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> combiner) {

return combineLatest(Functions.toFunction(combiner), false, bufferSize(), p1, p2, p3, p4);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T1, T2, T3, T4, T5, R> NbpObservable<R> combineLatest(

NbpObservable<? extends T1> p1, NbpObservable<? extends T2> p2,

NbpObservable<? extends T3> p3, NbpObservable<? extends T4> p4,

NbpObservable<? extends T5> p5,

Function5<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> combiner) {

return combineLatest(Functions.toFunction(combiner), false, bufferSize(), p1, p2, p3, p4, p5);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T1, T2, T3, T4, T5, T6, R> NbpObservable<R> combineLatest(

NbpObservable<? extends T1> p1, NbpObservable<? extends T2> p2,

NbpObservable<? extends T3> p3, NbpObservable<? extends T4> p4,

NbpObservable<? extends T5> p5, NbpObservable<? extends T6> p6,

Function6<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> combiner) {

return combineLatest(Functions.toFunction(combiner), false, bufferSize(), p1, p2, p3, p4, p5, p6);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T1, T2, T3, T4, T5, T6, T7, R> NbpObservable<R> combineLatest(

NbpObservable<? extends T1> p1, NbpObservable<? extends T2> p2,

NbpObservable<? extends T3> p3, NbpObservable<? extends T4> p4,

NbpObservable<? extends T5> p5, NbpObservable<? extends T6> p6,

NbpObservable<? extends T7> p7,

Function7<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> combiner) {

return combineLatest(Functions.toFunction(combiner), false, bufferSize(), p1, p2, p3, p4, p5, p6, p7);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T1, T2, T3, T4, T5, T6, T7, T8, R> NbpObservable<R> combineLatest(

NbpObservable<? extends T1> p1, NbpObservable<? extends T2> p2,

NbpObservable<? extends T3> p3, NbpObservable<? extends T4> p4,

NbpObservable<? extends T5> p5, NbpObservable<? extends T6> p6,

NbpObservable<? extends T7> p7, NbpObservable<? extends T8> p8,

Function8<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> combiner) {

return combineLatest(Functions.toFunction(combiner), false, bufferSize(), p1, p2, p3, p4, p5, p6, p7, p8);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> NbpObservable<R> combineLatest(

NbpObservable<? extends T1> p1, NbpObservable<? extends T2> p2,

NbpObservable<? extends T3> p3, NbpObservable<? extends T4> p4,

NbpObservable<? extends T5> p5, NbpObservable<? extends T6> p6,

NbpObservable<? extends T7> p7, NbpObservable<? extends T8> p8,

NbpObservable<? extends T9> p9,

Function9<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> combiner) {

return combineLatest(Functions.toFunction(combiner), false, bufferSize(), p1, p2, p3, p4, p5, p6, p7, p8, p9);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> concat(int prefetch, Iterable<? extends NbpObservable<? extends T>> sources) {

Objects.requireNonNull(sources, "sources is null");

return fromIterable(sources).concatMap((Function)Functions.identity(), prefetch);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> concat(Iterable<? extends NbpObservable<? extends T>> sources) {

Objects.requireNonNull(sources, "sources is null");

return fromIterable(sources).concatMap((Function)Functions.identity());

}

@SchedulerSupport(SchedulerKind.NONE)

public static final <T> NbpObservable<T> concat(NbpObservable<? extends NbpObservable<? extends T>> sources) {

return concat(sources, bufferSize());

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static final <T> NbpObservable<T> concat(NbpObservable<? extends NbpObservable<? extends T>> sources, int bufferSize) {

return sources.concatMap((Function)Functions.identity());

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> concat(NbpObservable<? extends T> p1, NbpObservable<? extends T> p2) {

return concatArray(p1, p2);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> concat(

NbpObservable<? extends T> p1, NbpObservable<? extends T> p2,

NbpObservable<? extends T> p3) {

return concatArray(p1, p2, p3);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> concat(

NbpObservable<? extends T> p1, NbpObservable<? extends T> p2,

NbpObservable<? extends T> p3, NbpObservable<? extends T> p4) {

return concatArray(p1, p2, p3, p4);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> concat(

NbpObservable<? extends T> p1, NbpObservable<? extends T> p2,

NbpObservable<? extends T> p3, NbpObservable<? extends T> p4,

NbpObservable<? extends T> p5

) {

return concatArray(p1, p2, p3, p4, p5);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> concat(

NbpObservable<? extends T> p1, NbpObservable<? extends T> p2,

NbpObservable<? extends T> p3, NbpObservable<? extends T> p4,

NbpObservable<? extends T> p5, NbpObservable<? extends T> p6

) {

return concatArray(p1, p2, p3, p4, p5, p6);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> concat(

NbpObservable<? extends T> p1, NbpObservable<? extends T> p2,

NbpObservable<? extends T> p3, NbpObservable<? extends T> p4,

NbpObservable<? extends T> p5, NbpObservable<? extends T> p6,

NbpObservable<? extends T> p7

) {

return concatArray(p1, p2, p3, p4, p5, p6, p7);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> concat(

NbpObservable<? extends T> p1, NbpObservable<? extends T> p2,

NbpObservable<? extends T> p3, NbpObservable<? extends T> p4,

NbpObservable<? extends T> p5, NbpObservable<? extends T> p6,

NbpObservable<? extends T> p7, NbpObservable<? extends T> p8

) {

return concatArray(p1, p2, p3, p4, p5, p6, p7, p8);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> concat(

NbpObservable<? extends T> p1, NbpObservable<? extends T> p2,

NbpObservable<? extends T> p3, NbpObservable<? extends T> p4,

NbpObservable<? extends T> p5, NbpObservable<? extends T> p6,

NbpObservable<? extends T> p7, NbpObservable<? extends T> p8,

NbpObservable<? extends T> p9

) {

return concatArray(p1, p2, p3, p4, p5, p6, p7, p8, p9);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> concatArray(int prefetch, NbpObservable<? extends T>... sources) {

Objects.requireNonNull(sources, "sources is null");

return fromArray(sources).concatMap((Function)Functions.identity(), prefetch);

}

/**

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> concatArray(NbpObservable<? extends T>... sources) {

if (sources.length == 0) {

return empty();

} else

if (sources.length == 1) {

return (NbpObservable<T>)sources[0];

}

return fromArray(sources).concatMap((Function)Functions.identity());

}

public static <T> NbpObservable<T> create(NbpOnSubscribe<T> onSubscribe) {

Objects.requireNonNull(onSubscribe, "onSubscribe is null");

// TODO plugin wrapper

return new NbpObservable<T>(onSubscribe);

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> defer(Supplier<? extends NbpObservable<? extends T>> supplier) {

Objects.requireNonNull(supplier, "supplier is null");

return create(new NbpOnSubscribeDefer<T>(supplier));

}

@SchedulerSupport(SchedulerKind.NONE)

@SuppressWarnings("unchecked")

public static <T> NbpObservable<T> empty() {

return (NbpObservable<T>)EMPTY;

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> error(Supplier<? extends Throwable> errorSupplier) {

Objects.requireNonNull(errorSupplier, "errorSupplier is null");

return create(new NbpOnSubscribeErrorSource<T>(errorSupplier));

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> error(final Throwable e) {

Objects.requireNonNull(e, "e is null");

return error(new Supplier<Throwable>() {

@Override

public Throwable get() {

return e;

}

});

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> fromArray(T... values) {

Objects.requireNonNull(values, "values is null");

if (values.length == 0) {

return empty();

} else

if (values.length == 1) {

return just(values[0]);

}

return create(new NbpOnSubscribeArraySource<T>(values));

}

// TODO match naming with RxJava 1.x

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> fromCallable(Callable<? extends T> supplier) {

Objects.requireNonNull(supplier, "supplier is null");

return create(new NbpOnSubscribeScalarAsyncSource<T>(supplier));

}

/*

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> fromFuture(Future<? extends T> future) {

Objects.requireNonNull(future, "future is null");

return create(new NbpOnSubscribeFutureSource<T>(future, 0L, null));

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> fromFuture(Future<? extends T> future, long timeout, TimeUnit unit) {

Objects.requireNonNull(future, "future is null");

Objects.requireNonNull(unit, "unit is null");

NbpObservable<T> o = create(new NbpOnSubscribeFutureSource<T>(future, timeout, unit));

return o;

}

@SchedulerSupport(SchedulerKind.CUSTOM)

public static <T> NbpObservable<T> fromFuture(Future<? extends T> future, long timeout, TimeUnit unit, Scheduler scheduler) {

Objects.requireNonNull(scheduler, "scheduler is null");

NbpObservable<T> o = fromFuture(future, timeout, unit);

return o.subscribeOn(scheduler);

}

@SchedulerSupport(SchedulerKind.IO)

public static <T> NbpObservable<T> fromFuture(Future<? extends T> future, Scheduler scheduler) {

Objects.requireNonNull(scheduler, "scheduler is null");

NbpObservable<T> o = fromFuture(future);

return o.subscribeOn(Schedulers.io());

}

public static <T> NbpObservable<T> fromIterable(Iterable<? extends T> source) {

Objects.requireNonNull(source, "source is null");

return create(new NbpOnSubscribeIterableSource<T>(source));

}

public static <T> NbpObservable<T> fromPublisher(final Publisher<? extends T> publisher) {

Objects.requireNonNull(publisher, "publisher is null");

return create(new NbpOnSubscribe<T>() {

@Override

public void accept(final NbpSubscriber<? super T> s) {

publisher.subscribe(new Subscriber<T>() {

@Override

public void onComplete() {

s.onComplete();

}

@Override

public void onError(Throwable t) {

s.onError(t);

}

@Override

public void onNext(T t) {

s.onNext(t);

}

@Override

public void onSubscribe(Subscription inner) {

s.onSubscribe(Disposables.from(inner));

inner.request(Long.MAX_VALUE);

}

});

}

});

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> generate(final Consumer<NbpSubscriber<T>> generator) {

Objects.requireNonNull(generator, "generator is null");

return generate(Functions.<Object>nullSupplier(),

new BiFunction<Object, NbpSubscriber<T>, Object>() {

@Override

public Object apply(Object s, NbpSubscriber<T> o) {

generator.accept(o);

return s;

}

}, Functions.<Object>emptyConsumer());

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T, S> NbpObservable<T> generate(Supplier<S> initialState, final BiConsumer<S, NbpSubscriber<T>> generator) {

Objects.requireNonNull(generator, "generator is null");

return generate(initialState, new BiFunction<S, NbpSubscriber<T>, S>() {

@Override

public S apply(S s, NbpSubscriber<T> o) {

generator.accept(s, o);

return s;

}

}, Functions.emptyConsumer());

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T, S> NbpObservable<T> generate(

final Supplier<S> initialState,

final BiConsumer<S, NbpSubscriber<T>> generator,

Consumer<? super S> disposeState) {

Objects.requireNonNull(generator, "generator is null");

return generate(initialState, new BiFunction<S, NbpSubscriber<T>, S>() {

@Override

public S apply(S s, NbpSubscriber<T> o) {

generator.accept(s, o);

return s;

}

}, disposeState);

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T, S> NbpObservable<T> generate(Supplier<S> initialState, BiFunction<S, NbpSubscriber<T>, S> generator) {

return generate(initialState, generator, Functions.emptyConsumer());

}

@SchedulerSupport(SchedulerKind.NONE)

public static <T, S> NbpObservable<T> generate(Supplier<S> initialState, BiFunction<S, NbpSubscriber<T>, S> generator, Consumer<? super S> disposeState) {

Objects.requireNonNull(initialState, "initialState is null");

Objects.requireNonNull(generator, "generator is null");

Objects.requireNonNull(disposeState, "diposeState is null");

return create(new NbpOnSubscribeGenerate<T, S>(initialState, generator, disposeState));

}

@SchedulerSupport(SchedulerKind.COMPUTATION)

public static NbpObservable<Long> interval(long initialDelay, long period, TimeUnit unit) {

return interval(initialDelay, period, unit, Schedulers.computation());

}

@SchedulerSupport(SchedulerKind.CUSTOM)

public static NbpObservable<Long> interval(long initialDelay, long period, TimeUnit unit, Scheduler scheduler) {

if (initialDelay < 0) {

initialDelay = 0L;

}

if (period < 0) {

period = 0L;

}

Objects.requireNonNull(unit, "unit is null");

Objects.requireNonNull(scheduler, "scheduler is null");

return create(new NbpOnSubscribeIntervalSource(initialDelay, period, unit, scheduler));

}

@SchedulerSupport(SchedulerKind.COMPUTATION)

public static NbpObservable<Long> interval(long period, TimeUnit unit) {

return interval(period, period, unit, Schedulers.computation());

}

@SchedulerSupport(SchedulerKind.CUSTOM)

public static NbpObservable<Long> interval(long period, TimeUnit unit, Scheduler scheduler) {

return interval(period, period, unit, scheduler);

}

@SchedulerSupport(SchedulerKind.COMPUTATION)

public static NbpObservable<Long> intervalRange(long start, long count, long initialDelay, long period, TimeUnit unit) {

return intervalRange(start, count, initialDelay, period, unit, Schedulers.computation());

}

@SchedulerSupport(SchedulerKind.CUSTOM)

public static NbpObservable<Long> intervalRange(long start, long count, long initialDelay, long period, TimeUnit unit, Scheduler scheduler) {

long end = start + (count - 1);

if (end < 0) {

throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");

}

if (initialDelay < 0) {

initialDelay = 0L;

}

if (period < 0) {

period = 0L;

}

Objects.requireNonNull(unit, "unit is null");

Objects.requireNonNull(scheduler, "scheduler is null");

return create(new NbpOnSubscribeIntervalRangeSource(start, end, initialDelay, period, unit, scheduler));

}

public static <T> NbpObservable<T> just(T value) {

Objects.requireNonNull(value, "The value is null");

return new NbpObservableScalarSource<T>(value);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static final <T> NbpObservable<T> just(T v1, T v2) {

Objects.requireNonNull(v1, "The first value is null");

Objects.requireNonNull(v2, "The second value is null");

return fromArray(v1, v2);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static final <T> NbpObservable<T> just(T v1, T v2, T v3) {

Objects.requireNonNull(v1, "The first value is null");

Objects.requireNonNull(v2, "The second value is null");

Objects.requireNonNull(v3, "The third value is null");

return fromArray(v1, v2, v3);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static final <T> NbpObservable<T> just(T v1, T v2, T v3, T v4) {

Objects.requireNonNull(v1, "The first value is null");

Objects.requireNonNull(v2, "The second value is null");

Objects.requireNonNull(v3, "The third value is null");

Objects.requireNonNull(v4, "The fourth value is null");

return fromArray(v1, v2, v3, v4);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static final <T> NbpObservable<T> just(T v1, T v2, T v3, T v4, T v5) {

Objects.requireNonNull(v1, "The first value is null");

Objects.requireNonNull(v2, "The second value is null");

Objects.requireNonNull(v3, "The third value is null");

Objects.requireNonNull(v4, "The fourth value is null");

Objects.requireNonNull(v5, "The fifth value is null");

return fromArray(v1, v2, v3, v4, v5);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static final <T> NbpObservable<T> just(T v1, T v2, T v3, T v4, T v5, T v6) {

Objects.requireNonNull(v1, "The first value is null");

Objects.requireNonNull(v2, "The second value is null");

Objects.requireNonNull(v3, "The third value is null");

Objects.requireNonNull(v4, "The fourth value is null");

Objects.requireNonNull(v5, "The fifth value is null");

Objects.requireNonNull(v6, "The sixth value is null");

return fromArray(v1, v2, v3, v4, v5, v6);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static final <T> NbpObservable<T> just(T v1, T v2, T v3, T v4, T v5, T v6, T v7) {

Objects.requireNonNull(v1, "The first value is null");

Objects.requireNonNull(v2, "The second value is null");

Objects.requireNonNull(v3, "The third value is null");

Objects.requireNonNull(v4, "The fourth value is null");

Objects.requireNonNull(v5, "The fifth value is null");

Objects.requireNonNull(v6, "The sixth value is null");

Objects.requireNonNull(v7, "The seventh value is null");

return fromArray(v1, v2, v3, v4, v5, v6, v7);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static final <T> NbpObservable<T> just(T v1, T v2, T v3, T v4, T v5, T v6, T v7, T v8) {

Objects.requireNonNull(v1, "The first value is null");

Objects.requireNonNull(v2, "The second value is null");

Objects.requireNonNull(v3, "The third value is null");

Objects.requireNonNull(v4, "The fourth value is null");

Objects.requireNonNull(v5, "The fifth value is null");

Objects.requireNonNull(v6, "The sixth value is null");

Objects.requireNonNull(v7, "The seventh value is null");

Objects.requireNonNull(v8, "The eigth value is null");

return fromArray(v1, v2, v3, v4, v5, v6, v7, v8);

}

@SuppressWarnings("unchecked")

@SchedulerSupport(SchedulerKind.NONE)

public static final <T> NbpObservable<T> just(T v1, T v2, T v3, T v4, T v5, T v6, T v7, T v8, T v9) {

Objects.requireNonNull(v1, "The first value is null");

Objects.requireNonNull(v2, "The second value is null");

Objects.requireNonNull(v3, "The third value is null");

Objects.requireNonNull(v4, "The fourth value is null");

Objects.requireNonNull(v5, "The fifth value is null");

Objects.requireNonNull(v6, "The sixth value is null");

Objects.requireNonNull(v7, "The seventh value is null");

Objects.requireNonNull(v8, "The eigth value is null");

Objects.requireNonNull(v9, "The ninth is null");

return fromArray(v1, v2, v3, v4, v5, v6, v7, v8, v9);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> merge(int maxConcurrency, int bufferSize, Iterable<? extends NbpObservable<? extends T>> sources) {

return fromIterable(sources).flatMap((Function)Functions.identity(), false, maxConcurrency, bufferSize);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> merge(int maxConcurrency, int bufferSize, NbpObservable<? extends T>... sources) {

return fromArray(sources).flatMap((Function)Functions.identity(), false, maxConcurrency, bufferSize);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> merge(int maxConcurrency, NbpObservable<? extends T>... sources) {

return fromArray(sources).flatMap((Function)Functions.identity(), maxConcurrency);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> merge(Iterable<? extends NbpObservable<? extends T>> sources) {

return fromIterable(sources).flatMap((Function)Functions.identity());

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> merge(Iterable<? extends NbpObservable<? extends T>> sources, int maxConcurrency) {

return fromIterable(sources).flatMap((Function)Functions.identity(), maxConcurrency);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

public static <T> NbpObservable<T> merge(NbpObservable<? extends NbpObservable<? extends T>> sources) {

return sources.flatMap((Function)Functions.identity());

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> merge(NbpObservable<? extends NbpObservable<? extends T>> sources, int maxConcurrency) {

return sources.flatMap((Function)Functions.identity(), maxConcurrency);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@BackpressureSupport(BackpressureKind.FULL)

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> merge(NbpObservable<? extends T> p1, NbpObservable<? extends T> p2) {

Objects.requireNonNull(p1, "p1 is null");

Objects.requireNonNull(p2, "p2 is null");

return fromArray(p1, p2).flatMap((Function)Functions.identity(), false, 2);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@BackpressureSupport(BackpressureKind.FULL)

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> merge(NbpObservable<? extends T> p1, NbpObservable<? extends T> p2, NbpObservable<? extends T> p3) {

Objects.requireNonNull(p1, "p1 is null");

Objects.requireNonNull(p2, "p2 is null");

Objects.requireNonNull(p3, "p3 is null");

return fromArray(p1, p2, p3).flatMap((Function)Functions.identity(), false, 3);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@BackpressureSupport(BackpressureKind.FULL)

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> merge(

NbpObservable<? extends T> p1, NbpObservable<? extends T> p2,

NbpObservable<? extends T> p3, NbpObservable<? extends T> p4) {

Objects.requireNonNull(p1, "p1 is null");

Objects.requireNonNull(p2, "p2 is null");

Objects.requireNonNull(p3, "p3 is null");

Objects.requireNonNull(p4, "p4 is null");

return fromArray(p1, p2, p3, p4).flatMap((Function)Functions.identity(), false, 4);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> merge(NbpObservable<? extends T>... sources) {

return fromArray(sources).flatMap((Function)Functions.identity(), sources.length);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> mergeDelayError(boolean delayErrors, Iterable<? extends NbpObservable<? extends T>> sources) {

return fromIterable(sources).flatMap((Function)Functions.identity(), true);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> mergeDelayError(int maxConcurrency, int bufferSize, Iterable<? extends NbpObservable<? extends T>> sources) {

return fromIterable(sources).flatMap((Function)Functions.identity(), true, maxConcurrency, bufferSize);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> mergeDelayError(int maxConcurrency, int bufferSize, NbpObservable<? extends T>... sources) {

return fromArray(sources).flatMap((Function)Functions.identity(), true, maxConcurrency, bufferSize);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> mergeDelayError(int maxConcurrency, Iterable<? extends NbpObservable<? extends T>> sources) {

return fromIterable(sources).flatMap((Function)Functions.identity(), true, maxConcurrency);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> mergeDelayError(int maxConcurrency, NbpObservable<? extends T>... sources) {

return fromArray(sources).flatMap((Function)Functions.identity(), true, maxConcurrency);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

public static <T> NbpObservable<T> mergeDelayError(NbpObservable<? extends NbpObservable<? extends T>> sources) {

return sources.flatMap((Function)Functions.identity(), true);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> mergeDelayError(NbpObservable<? extends NbpObservable<? extends T>> sources, int maxConcurrency) {

return sources.flatMap((Function)Functions.identity(), true, maxConcurrency);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@BackpressureSupport(BackpressureKind.FULL)

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> mergeDelayError(NbpObservable<? extends T> p1, NbpObservable<? extends T> p2) {

Objects.requireNonNull(p1, "p1 is null");

Objects.requireNonNull(p2, "p2 is null");

return fromArray(p1, p2).flatMap((Function)Functions.identity(), true, 2);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@BackpressureSupport(BackpressureKind.FULL)

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> mergeDelayError(NbpObservable<? extends T> p1, NbpObservable<? extends T> p2, NbpObservable<? extends T> p3) {

Objects.requireNonNull(p1, "p1 is null");

Objects.requireNonNull(p2, "p2 is null");

Objects.requireNonNull(p3, "p3 is null");

return fromArray(p1, p2, p3).flatMap((Function)Functions.identity(), true, 3);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@BackpressureSupport(BackpressureKind.FULL)

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> mergeDelayError(

NbpObservable<? extends T> p1, NbpObservable<? extends T> p2,

NbpObservable<? extends T> p3, NbpObservable<? extends T> p4) {

Objects.requireNonNull(p1, "p1 is null");

Objects.requireNonNull(p2, "p2 is null");

Objects.requireNonNull(p3, "p3 is null");

Objects.requireNonNull(p4, "p4 is null");

return fromArray(p1, p2, p3, p4).flatMap((Function)Functions.identity(), true, 4);

}

@SuppressWarnings({ "unchecked", "rawtypes" })

@SchedulerSupport(SchedulerKind.NONE)

public static <T> NbpObservable<T> mergeDelayError(NbpObservable<? extends T>... sources) {

return fromArray(sources).flatMap((Function)Functions.identity(), true, sources.length);

}

@SchedulerSupport(SchedulerKind.NONE)

@SuppressWarnings("unchecked")

public static <T> NbpObservable<T> never() {

return (NbpObservable<T>)NEVER;

}

@SchedulerSupport(SchedulerKind.NONE)

public static NbpObservable<Integer> range(final int start, final int count) {

if (count < 0) {

throw new IllegalArgumentException("count >= required but it was " + count);

} else

if (count == 0) {

return empty();

} else

if (count == 1) {

return just(start);

} else

if ((long)start + (count - 1) > Integer.MAX_VALUE) {

throw new IllegalArgumentException("Integer overflow");

}

return create(new NbpOnSubscribe<Integer>() {

@Override

public void accept(NbpSubscriber<? super Integer> s) {

BooleanDisposable d = new BooleanDisposable();

s.onSubscribe(d);

long end = start - 1L + count;

for (long i = start; i <= end && !d.isDisposed(); i++) {

s.onNext((int)i);

}

if (!d.isDisposed()) {

s.onComplete();

}

}