官术网_书友最值得收藏!

Single

Single<T> is essentially an Observable<T> that will only emit one item. It works just like an Observable, but it is limited only to operators that make sense for a single emission. It has its own SingleObserver interface as well:

    interface SingleObserver<T> {
void onSubscribe(Disposable d);
void onSuccess(T value);
void onError(Throwable error);
}

The onSuccess() essentially consolidates onNext() and onComplete() into a single event that accepts the one emission. When you call subscribe() against a Single, you provide the lambdas for onSuccess() as well as an optional onError():

    import io.reactivex.Single;

public class Launcher {

public static void main(String[] args) {
Single.just("Hello")
.map(String::length)
.subscribe(System.out::println,
Throwable::printStackTrace
);
}
}

Certain RxJava Observable operators will yield a Single, as we will see in the next chapter. For instance, the first() operator will return a Single since that operator is logically concerned with a single item. However, it accepts a default value as a parameter (which I specified as Nil in the following example) if the Observable comes out empty: 

    import io.reactivex.Observable;

public class Launcher {

public static void main(String[] args) {
Observable<String> source =
Observable.just("Alpha","Beta","Gamma");

source.first("Nil") //returns a Single
.subscribe(System.out::println);
}
}

The output is as follows:

    Alpha

The Single must have one emission, and you should prefer it if you only have one emission to provide. This means that instead of using Observable.just("Alpha"), you should try to use Single.just("Alpha") instead. There are operators on Single that will allow you to turn it into an Observable when needed, such as toObservable().

If there are 0 or 1 emissions, you will want to use Maybe.

主站蜘蛛池模板: 磴口县| 电白县| 凤阳县| 宜良县| 西贡区| 西吉县| 修水县| 玉屏| 陇川县| 普格县| 溆浦县| 阜南县| 清镇市| 沛县| 隆子县| 常德市| 新乐市| 清新县| 邮箱| 淄博市| 沙湾县| 平阳县| 思南县| 浑源县| 平南县| 临清市| 昌黎县| 雅安市| 左云县| 开封县| 天等县| 蕉岭县| 巴楚县| 漾濞| 扎兰屯市| 普格县| 宁明县| 莱芜市| 郯城县| 瑞金市| 荥经县|