6. RxSwift 订阅操作过滤1 map、buffer、filter

2021-03-14 19:34

阅读：907

标签：sch async swift mmm shu 个数返回搬迁处理

map

同 Swift中 map 用法一样，对值进行处理并返回

let sub = PublishSubject()

sub.map { $0 + "mmmmm" }
    .subscribe { event in
        print(event.element)
    }
    .disposed(by: disposeBag)
sub.onNext("a")
//Optional("ammmmm")

buffer

timeSpan 缓存间隔时间、 count 缓存个数、 scheduler 线程
发送两个event后会触发订阅。满 2 秒也会触发订阅，如果event 没有发送空数组

let sub = PublishSubject()
sub.buffer(timeSpan: 2, count: 2, scheduler: MainScheduler.asyncInstance)
    .subscribe { event in
        print("订阅1", event)
    }.disposed(by: disposeBag)

sub.onNext("发送1")
sub.onNext("发送2")

filter

过滤同Swift中filter一样

let ob = Observable.of(10, 11, 12, 99, 33, 55, 77)
ob.filter { $0 > 20
}.subscribe(onNext: { element in
    print(element)
}).disposed(by: disposeBag)

搬迁自本人简书

6. RxSwift 订阅操作过滤1 map、buffer、filter

标签：sch async swift mmm shu 个数返回搬迁处理

原文地址：https://www.cnblogs.com/i2yf/p/14016621.html

上一篇：7. RxSwift 订阅操作过滤2 distinctUntilChanged、single、elementAt、ignoreElements、take、takeLast、skip、debounce

下一篇：java接口

文章来自：搜素材网的编程语言模块，转载请注明文章出处。
文章标题：6. RxSwift 订阅操作过滤1 map、buffer、filter
文章链接：http://soscw.com/essay/64677.html

亲，登录后才可以留言！

6. RxSwift 订阅操作过滤1 map、buffer、filter

map

buffer

filter

评论

热门文章

推荐文章

最新文章

置顶文章