小文字 吃饭，睡觉，遛狗头

Rx那些不怎么好理解的点

2016-05-5 小文字

img

前言

学习Rx的相关知识，一定要去Reactive.io, 但是我在看了其中的一些operation的说明后，有几个操作让人一头雾水:

Debounce or Sample

debounce的原因大致是“去抖动; 防抖动; 弹跳;”，sample的意思是采样，抽样；从Reactivex.io上的介绍来看，两者非常相似； 有一个显著差别是，

  1. debounce函数过滤掉由Observable发射的速率过快的数据；如果在一个指定的时间间隔过去了仍旧没有发射一个，那么它将发射最后的那个。 debounce

  2. sample定期从Observable发射的数据中取最后一个，如果某个时期内没有数据发射，那么这段时期内就没有被观察的数据，他不会发射最后一个； sample

First or Single

两者都是只从数据源中返回一个符合条件的数据，但是single在Observable结束时都没有合适的数据时会抛出一个NoSuchElementException异常 first

single

Event Bus

在Rx流行起来之前很多开发都接触过EventBus(事件总线),事件总线用的是发布-订阅模式，和Rx的观察者模式非常相像，不过事件总线更加关注消息的广播，在解耦这件事上大家都是通过中间人在处理，从而达到消息生成和消费之间无关。
在引入Rx之后我们甚至也能实现RxBug，现在我们一起看一下：

public class RxBus {

  private final Subject<Object, Object> _bus = new SerializedSubject<>(PublishSubject.create());

  public void send(Object o) {
    _bus.onNext(o);
  }

  public Observable<Object> toObserverable() {
    return _bus;
  }
}
@OnClick(R.id.btn_demo_rxbus_tap)
public void onTapButtonClicked() {

    _rxBus.send(new TapEvent());
}
_rxBus.toObserverable()
    .subscribe(new Action1<Object>() {
      @Override
      public void call(Object event) {

        if(event instanceof TapEvent) {
          _showTapText();

        }else if(event instanceof SomeOtherEvent) {
          _doSomethingElse();
        }
      }
    });

短短几行代码就可以实现事件总线中的中间人角色；

PublishSubject

参考

Related Posts