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 嗯,我大概理解了 |