backpressure_test:测试OperatorDoOnSubscribe和OperatorDoOnUnsubscribe是否弄乱了背压处理

时间:2024-06-12 22:59:57
【文件属性】:

文件名称:backpressure_test:测试OperatorDoOnSubscribe和OperatorDoOnUnsubscribe是否弄乱了背压处理

文件大小:86KB

文件格式:ZIP

更新时间:2024-06-12 22:59:57

Java

在使用Observable doOnSubscribe和doOnUnsubscribe方法时遇到了一些奇怪的行为。 原因是那些方法使用运算符OperatorDoOnSubscribe和OperatorDoOnUnsubscribe 。 public class OperatorDoOnSubscribe implements Operator< T> { private final Action0 subscribe; /** * Constructs an instance of the operator with the callback that gets invoked when the modified Observable is subscribed * @param subscribe the action that


【文件预览】:
backpressure_test-master
----.gitignore(91B)
----gradle()
--------wrapper()
----BackpressureTest.iml(947B)
----README.md(4KB)
----build.gradle(436B)
----gradlew.bat(2KB)
----gradlew(5KB)
----app()
--------.gitignore(7B)
--------build.gradle(692B)
--------proguard-rules.pro(653B)
--------app.iml(8KB)
--------src()
----gradle.properties(855B)
----.idea()
--------runConfigurations.xml(564B)
--------vcs.xml(180B)
--------misc.xml(3KB)
--------modules.xml(369B)
--------.name(17B)
--------copyright()
--------compiler.xml(686B)
--------gradle.xml(684B)
----settings.gradle(15B)

网友评论