1
wuz 2019-01-22 18:07:59 +08:00
看看 Subject
|
2
jinhan13789991 2019-01-22 18:11:14 +08:00
后面有数据 是指什么时候~
|
3
symeonchen 2019-01-22 18:17:32 +08:00 via Android
PublishSubject
|
4
beginor 2019-01-22 19:05:50 +08:00 via Android
支持一下,刚好也在看这个。 用 Subject 或者 BehaviorSubject, 然后调用 next 方法
|
5
wly19960911 2019-01-22 19:53:39 +08:00
一般我是直接创建一个全局的变量,并且里面有 subject,然后修改之后通过 subject 去处理,然后 subscribe 就会响应这个异步操作。
https://rxjs-cn.github.io/learn-rxjs-operators/ 顺便补一下 rxjs 操作符吧。这个教程写的很好了 |
6
wly19960911 2019-01-22 19:54:12 +08:00
@wly19960911 #5 忘记说了,这个作为一个 service 注册到 provider 里面去。
|
7
wly19960911 2019-01-22 19:59:04 +08:00
......看了下,是 rxjava 丢人了(抱歉了楼主
|
8
stdying OP |
9
stdying OP |
10
stdying OP @wly19960911 不太理解你的意思,你理解,说明你优秀
|
11
wly19960911 2019-01-23 10:20:14 +08:00
@stdying #10 我看错了,我以为是 rxjs,理念是一样的,subject 其实就是一个事件订阅的机器。创建一个机器然后开始走流水线,使用 subject next 方法把数据丢进去,走你所定义的流处理过程然后最后到 subscribe 的位置。实际上这个 subject 应该需要全局定义的吧,java 写得少,是我的话应该直接 static 了。
|
12
stdying OP @wly19960911 嗯,我大概理解了
|