import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public T[] getValues(T[] a) {
    Object o = this.state.getLatest();
    if (this.nl.isNext(o)) {
        if (a.length == 0) {
            a = (Object[]) ((Object[]) Array.newInstance(a.getClass().getComponentType(), 1));
        }
        a[0] = this.nl.getValue(o);
        if (a.length > 1) {
            a[1] = null;
        }
    } else if (a.length > 0) {
        a[0] = null;
    }
    return a;
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public final <R> Observable<R> flatMap(Func1<? super T, ? extends Observable<? extends R>> func, int maxConcurrent) {
    if (getClass() == ScalarSynchronousObservable.class) {
        return ((ScalarSynchronousObservable) this).scalarFlatMap(func);
    }
    return merge(map(func), maxConcurrent);
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public Throwable getThrowable() {
    NotificationLite<T> nl = this.ssm.nl;
    Object o = this.ssm.getLatest();
    if (nl.isError(o)) {
        return nl.getError(o);
    }
    return null;
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public Object[] getValues() {
    T[] r = getValues(EMPTY_ARRAY);
    if (r == EMPTY_ARRAY) {
        return new Object[0];
    }
    return r;
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public T getValue() {
    Object v = this.lastValue;
    if (this.nl.isError(this.state.getLatest()) || !this.nl.isNext(v)) {
        return null;
    }
    return this.nl.getValue(v);
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public Throwable getThrowable() {
    Object o = this.state.getLatest();
    if (this.nl.isError(o)) {
        return this.nl.getError(o);
    }
    return null;
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public T getValue() {
    Object o = this.state.getLatest();
    if (this.nl.isNext(o)) {
        return this.nl.getValue(o);
    }
    return null;
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public Observable<T> autoConnect(int numberOfSubscribers, Action1<? super Subscription> connection) {
    if (numberOfSubscribers > 0) {
        return create(new OnSubscribeAutoConnect(this, numberOfSubscribers, connection));
    }
    connect(connection);
    return this;
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public final String handleOnNextValueRendering(Object item) {
    try {
        return render(item);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
        return item.getClass().getName() + ERROR_IN_RENDERING_SUFFIX;
    } catch (Throwable t) {
        Exceptions.throwIfFatal(t);
        return item.getClass().getName() + ERROR_IN_RENDERING_SUFFIX;
    }
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public static <S, T> Observable<T> create(SyncOnSubscribe<S, T> syncOnSubscribe) {
    return new Observable(hook.onCreate(syncOnSubscribe));
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public Single<T> toSingle() {
    return new Single(OnSubscribeSingle.create(this));
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public static <T> Observable<T> fromCallable(Callable<? extends T> func) {
    return create(new OnSubscribeFromCallable(func));
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public final Observable<T> doOnRequest(Action1<Long> onRequest) {
    return lift(new OperatorDoOnRequest(onRequest));
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public final <R> Observable<R> flatMapIterable(Func1<? super T, ? extends Iterable<? extends R>> collectionSelector, int maxConcurrent) {
    return OnSubscribeFlattenIterable.createFrom(this, collectionSelector, maxConcurrent);
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public boolean hasThrowable() {
    return this.ssm.nl.isError(this.ssm.getLatest());
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public boolean hasCompleted() {
    NotificationLite<T> nl = this.ssm.nl;
    Object o = this.ssm.getLatest();
    return (o == null || nl.isError(o)) ? false : true;
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public int size() {
    return this.state.size();
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public boolean hasAnyValue() {
    return !this.state.isEmpty();
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public boolean hasValue() {
    return hasAnyValue();
}
 

import rx.annotations.Beta; //导入依赖的package包/类
@Beta
public T getValue() {
    return this.state.latest();
}