Rxjava:订阅特定的帖子

Question

我是Rxjava的新手.我有以下代码:

    System.out.println("1: " + Thread.currentThread().getId());
    Observable.create(new rx.Observable.OnSubscribe<String>() {
        @Override
        public void call(Subscriber<? super String> subcriber) {
            System.out.println("2: " + Thread.currentThread().getId());
            // query database
            String result = ....
            subcriber.onNext(result);
        }

    }).subscribeOn(Schedulers.newThread()).subscribe(countResult -> {
        System.out.println("3: " + Thread.currentThread().getId());
    });

例如,输出将是:

1:50
2:100
3:100

我希望订阅者在ID为50的线程上运行.我该怎么做？

Answer 1

使用 RxJava 1.0.15，您可以toBlocking()在之前应用subscribe，所有内容都将在创建整个运算符序列的线程上运行。