Observable <T>から継承するにはどうすればよいですか?

Dmitri Nesteruk

から継承するイベントブローカークラスを構築したいと思いObservable<EventArgs>ます。Rxの.NET実装では、単純にIObservable<EventArgs>;を実装できます。さらに、.NETでは、このpublish()メソッドは、サブスクライバーに受信させたい引数を取ります。

誰かがこれがJavaでどのように行われるかを説明できますか?私が欲しいのは、本質的にとして振る舞うクラスですObservable<Foo>

オクネシフ

ほとんどの場合、独自のObservable継承を実装する必要はありません。Observableを作成し、その動作を処理するためのファブリックメソッドはたくさんあります。例えば:

Observable.create(new ObservableOnSubscribe<String>() {
    @Override public void subscribe(ObservableEmitter<String> emitter) throws Exception {
        emitter.onNext("New event");

        emitter.onError(new Error());

        emitter.onComplete();
    }
});

しかし、本当に継承を正確に作成する必要がある場合も、難しくはありません。

class MarkedObservable extends Observable<String> {

    @Override protected void subscribeActual(Observer<? super String> observer) {
        observer.onNext("Message");

        observer.onError(new Error());

        observer.onComplete();
    }
}

この記事はインターネットから収集されたものであり、転載の際にはソースを示してください。

侵害の場合は、連絡してください[email protected]

編集
0

コメントを追加

0

関連記事

分類Dev

Observable <Observable <T >>からObservable <T>

分類Dev

Observable <T>の最初の要素を各グループに追加するにはどうすればよいですか?

分類Dev

Observable <T []>からObservable <T> []へ

分類Dev

RxJavaはSingle <T>を導入しました。Observable <T>をSingle <T>に変換するにはどうすればよいですか?

分類Dev

計算された各アイテムをキャッシュするObservableを作成するにはどうすればよいですか?(Lazy <T>と同等)

分類Dev

Observable <Array <T >>からObservable <T>へ

分類Dev

継承でreactor.core.publisherMono <T>またはFlux <T>を使用するにはどうすればよいですか?

分類Dev

List <T>を継承する型にリストをキャストするにはどうすればよいですか?

分類Dev

redux observableの内部observableから退会するにはどうすればよいですか?

分類Dev

forkJoinによって返されたObservableから退会するにはどうすればよいですか?

分類Dev

Observable <Observable <List <T >>>をObservable <List <T >>に変換する方法

分類Dev

SFINAEのstd :: enable_if_t&std :: is_base_ofを使用して、コンパイル時の継承を確認するにはどうすればよいですか?

分類Dev

Angular 7では、Observableから結果を抽出するにはどうすればよいですか?

分類Dev

関数からObservable <T>をどのように返しますか

分類Dev

RxJSでObservableを完了するにはどうすればよいですか

分類Dev

Rx Observableで「待機」するにはどうすればよいですか?

分類Dev

AndroidでObservableを作成するにはどうすればよいですか?

分類Dev

redux-observableで「of」を使用するにはどうすればよいですか

分類Dev

Observable <BleHandler.BlePeripheral>からBleHandler.BlePeripheralに移動するにはどうすればよいですか?

分類Dev

Observable Angular 7から適切に登録を解除するにはどうすればよいですか?

分類Dev

Observableからデータを取得してInterceptorで使用するにはどうすればよいですか?

分類Dev

OnClick Event AndroidからObservableを作成するにはどうすればよいですか?

分類Dev

ObservableからのAjaxリクエストを中止するにはどうすればよいですか?

分類Dev

RxJS 5 observableから退会するにはどうすればよいですか?

分類Dev

FirestoreのObservableからエラーをキャッチするにはどうすればよいですか?

分類Dev

Rx Observableから値を抽出するにはどうすればよいですか?

分類Dev

Observableからデータを2回取得するにはどうすればよいですか?

分類Dev

別のObservable内のObservableを解決するにはどうすればよいですか?-rxjs

分類Dev

Observable.ajax(redux-observable)をテストするにはどうすればよいですか?

Related 関連記事

  1. 1

    Observable <Observable <T >>からObservable <T>

  2. 2

    Observable <T>の最初の要素を各グループに追加するにはどうすればよいですか?

  3. 3

    Observable <T []>からObservable <T> []へ

  4. 4

    RxJavaはSingle <T>を導入しました。Observable <T>をSingle <T>に変換するにはどうすればよいですか?

  5. 5

    計算された各アイテムをキャッシュするObservableを作成するにはどうすればよいですか?(Lazy <T>と同等)

  6. 6

    Observable <Array <T >>からObservable <T>へ

  7. 7

    継承でreactor.core.publisherMono <T>またはFlux <T>を使用するにはどうすればよいですか?

  8. 8

    List <T>を継承する型にリストをキャストするにはどうすればよいですか?

  9. 9

    redux observableの内部observableから退会するにはどうすればよいですか?

  10. 10

    forkJoinによって返されたObservableから退会するにはどうすればよいですか?

  11. 11

    Observable <Observable <List <T >>>をObservable <List <T >>に変換する方法

  12. 12

    SFINAEのstd :: enable_if_t&std :: is_base_ofを使用して、コンパイル時の継承を確認するにはどうすればよいですか?

  13. 13

    Angular 7では、Observableから結果を抽出するにはどうすればよいですか?

  14. 14

    関数からObservable <T>をどのように返しますか

  15. 15

    RxJSでObservableを完了するにはどうすればよいですか

  16. 16

    Rx Observableで「待機」するにはどうすればよいですか?

  17. 17

    AndroidでObservableを作成するにはどうすればよいですか?

  18. 18

    redux-observableで「of」を使用するにはどうすればよいですか

  19. 19

    Observable <BleHandler.BlePeripheral>からBleHandler.BlePeripheralに移動するにはどうすればよいですか?

  20. 20

    Observable Angular 7から適切に登録を解除するにはどうすればよいですか?

  21. 21

    Observableからデータを取得してInterceptorで使用するにはどうすればよいですか?

  22. 22

    OnClick Event AndroidからObservableを作成するにはどうすればよいですか?

  23. 23

    ObservableからのAjaxリクエストを中止するにはどうすればよいですか?

  24. 24

    RxJS 5 observableから退会するにはどうすればよいですか?

  25. 25

    FirestoreのObservableからエラーをキャッチするにはどうすればよいですか?

  26. 26

    Rx Observableから値を抽出するにはどうすればよいですか?

  27. 27

    Observableからデータを2回取得するにはどうすればよいですか?

  28. 28

    別のObservable内のObservableを解決するにはどうすればよいですか?-rxjs

  29. 29

    Observable.ajax(redux-observable)をテストするにはどうすればよいですか?

ホットタグ

アーカイブ