主页 / 问题 / 1021332
Accepted
Fangog
Asked:2020-09-08 03:32:46 +0000 UTC2020-09-08 03:32:46 +0000 UTC

如何使用 rxjava 进行消息传递？

  • 772

我有一个通过 UART 接收包的流

我需要所有订阅者接收这些包，即 就像是：

observable.send("Посылка");

可能我还是不太清楚，但是很奇怪rxjava只发送一次消息，在创建新类的时候，例如：

Observable<String> observable = Observable.from(new String[]{"one", "two", "three"});

那么如何向它发送消息呢？

java

1 个回答

  1. Best Answer

    要获取可以订阅和发送消息的对象，您需要使用Subject.

    示例：

    PublishSubject<Integer> subject = PublishSubject.create();
subject.onNext(1);
subject.subscribe(System.out::println);
subject.onNext(2);
subject.onNext(3);
subject.onNext(4);

    还有一个基于它的库，它提供了几个实现Subject-a，它可能很有用：RxRelay

    • 3

相关问题