takeUntil 自动取消订阅, 使用自定义装饰器取消订阅

takeUntil 操作符

takeUntil

该 Observable 第一次发出值会使 takeUntil 的 输出 Observable 停止发出由源 Observable 所发出的值。

示例:

var interval = Rx.Observable.interval(1000);
var clicks = Rx.Observable.fromEvent(document, 'click');

// 用 ‘clicks’ Observable来通知 ‘interval’ Observable 停止发出值
// 当我们点击页面时,定时器就会停止
var results = interval.takeUntil(clicks);

// 这种写法等同于 results.subscribe( x => console.log(x))
results.subscribe(console.log)
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,292评论 19 139
  • 原文链接: https://medium.com/@benlesh/rxjs-dont-unsubscribe-6...
    SangKa阅读 10,534评论 0 3
  • 本篇文章介主要绍RxJava中操作符是以函数作为基本单位,与响应式编程作为结合使用的,对什么是操作、操作符都有哪些...
    嘎啦果安卓兽阅读 7,898评论 0 10
  • http://blog.csdn.net/yyh352091626/article/details/5330472...
    奈何心善阅读 8,886评论 0 0
  • 参考:给 Android 开发者的 RxJava 详解-扔物线深入浅出RxJava 基础 "a library f...
    Vincen1024阅读 3,493评论 0 1