publishsubject

0熱

1答えて

Eventクラスは私のバスとして機能しているPublishRelayに投稿したいと思っています。私のRxBusポストイベントをジェネリック型にしたいのですが、バス自体は一般的ではありません。私は何を変える必要があるかについて私にアイデアを教えてもらえますか？あなたは、一般的なイベントを使用したい場合は public class Event<T> { protected String n

1熱

1答えて

なぜonSubscribeがrxjavaで動作しないのですか？

observeOn行を書き込まないとコードの下を実行すると、getView().showBlockLayout(isBlock);がレイアウトを非表示または表示しようとするため、アプリケーションがクラッシュします。ですが、observeOn(AndroidSchedulers.mainThread())以下をsubscribeOn(AndroidSchedulers.mainThread())に

2熱

1答えて

LatestFromで観測可能

I kotlinの拡張関数として "FilterByLatestFrom"という擬似演算子を実装しました。私は、この演算子を使用して次のコードを書いた： fun testFilterByLatestFromOperator(){ val observableA : Observable<Int> = Observable.fromArray(1,2,3,4,5,6,7,8,9,10)

0熱

1答えて

Asynctask status && RxJava2で同等のキャンセルが可能ですか？

私はRxJava2を学び、AsyncTasksをObservablesに変換しようとしています。変換しようとしている次のコードがあります。 if(asyncTask.getStatus() == AsyncTask.Status.RUNNING){ asyncTask.cancel(); } asyncTask = new CustomTask(); asyncTask.exec