使用时如何增加延迟。just()运算符

我用这个编码了一个可观察的。just()运算符,如代码中所示。 我想做的是,给操作符加一个延迟,这样在整数值发送给观测者之前,它应该延迟几秒钟

类似于:

mAsyncObservable = rx.Observable.create(new rx.Observable.OnSubscribe<Integer>() {
        @Override
        public void call(Subscriber<? super Integr> subscriber) {
            SystemClock.sleep(3000);

            subscriber.onNext(10);
            subscriber.onCompleted();
        }
    });

如何使用转换相同的代码。just()运算符?

:

Subscriber<Integer> integerSubscriber = new Subscriber<Integer>() {
    private final String SubscriberTag = "integerSubscriber";
    @Override
    public void onStart() {
        super.onStart();
        Log.w(TAG, "onStart->" + SubscriberTag);
    }

    @Override
    public void onCompleted() {
        Log.w(TAG, "onCompleted->" + SubscriberTag);
    }

    @Override
    public void onError(Throwable e) {
        Log.w(TAG, "onError->" + SubscriberTag + e.getMessage().toString());
    }

    @Override
    public void onNext(Integer i) {
        Log.w(TAG, "onNext->" + SubscriberTag + "after processing " + i);
    }
};

 @Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);


    rx.Observable<Integer> integerObservable = rx.Observable.just(10);
    integerObservable.subscribe(integerSubscriber);
}