rx-java 基础科目

2024-04-15 04:08:03 483

示例

SubjectRxJava中的A是既是Observable和又是的类Observer。这基本上意味着它可以充当Observable和将输入传递给订阅者，以及Observer从另一个Observable获取输入。

Subject<String, String> subject = PublishSubject.create(); subject.subscribe(System.out::print); subject.onNext("Hello, World!");

上面打印了“你好，世界！”使用进行控制台Subjects。

说明

代码的第一行定义一个新Subject的类型PublishSubject

Subject<String,String>subject=PublishSubject.create();
  |  |   |   |        |
subject<input,output> name =defaultpublishsubject

第二行订阅主题，显示Observer行为。

subject.subscribe(System.out::print);

这样一Subject来，用户就可以像普通订户一样接受输入

第三行调用onNext主题的方法，以显示Observable行为。

subject.onNext("Hello,World!");

这使能够Subject为所有订阅它的人提供输入。

种类

甲Subject（在RxJava）可以是任何这些四种类型：

异步主题

行为主体

发布主题

重播主题

另外，aSubject可以是typeSerializedSubject。此类型确保Subject不会违反可观察合同 （该合同规定所有调用都必须序列化）

进一步阅读：

使用或不使用DaveSexton博客中的主题

示例