Android第三方框架之Rxjava

android 第三方框架 Rxjava

Rxjava

BehaviorSubject

• Observer会接收到BehaviorSubject被订阅之前的最后一个数据，再接收其他发射过来的数据
• 如果BehaviorSubject被订阅之前没有发送任何数据，则会发送一个默认数据。这个默认数据是可选的

// BehaviorSubject behaviorSubject = BehaviorSubject.create();// 没有默认值
BehaviorSubject behaviorSubject = BehaviorSubject.create("-1");
behaviorSubject.onNext("1");
behaviorSubject.onNext("2");
  behaviorSubject.subscribe(new Observer() {
      @Override
      public void onCompleted() {
          LogUtil.log("behaviorSubject:complete");
      }
      @Override
      public void onError(Throwable e) {
          LogUtil.log("behaviorSubject:error");
      }
      @Override
      public void onNext(String s) {
          LogUtil.log("behaviorSubject:"+s);
      }
  });
  behaviorSubject.onNext("3");
  behaviorSubject.onNext("4");

• Observer会接收到2、3、4
• 如果在behaviorSubject.subscribe()之前不发送1、2，则Observer会依次接收到-1、3、4。

拾遗

壹 CompositeSubscription

clear和unsubscribe

CompositeSubscription.unsubscribe()解绑后无法继续add使用

• unsubscribe()
  CompositeSubscription对象就将不能再使用了，后续所有新添加进来的会马上进行解绑。如果想继续使用就只能重新创建对象。
• clear()
  绑定新的可以继续使用

public void clear() {
    if (!unsubscribed) {
        Collection<Subscription> unsubscribe;
        synchronized (this) {
            if (unsubscribed || subscriptions == null) {
                return;
            } else {
                unsubscribe = subscriptions;
                subscriptions = null;
            }
        }
        unsubscribeFromAll(unsubscribe);
    }
}
public void unsubscribe() {
    if (!unsubscribed) {
        Collection<Subscription> unsubscribe;
        synchronized (this) {
            if (unsubscribed) {
                return;
            }
            unsubscribed = true;
            unsubscribe = subscriptions;
            subscriptions = null;
        }
        // we will only get here once
        unsubscribeFromAll(unsubscribe);
    }
}

这两个方法其实就一个地方的差别，就是在unsubscribe()中将unsubscribed = true，那么这个有什么用呢？

public void add(final Subscription s) {
    if (s.isUnsubscribed()) {
        return;
    }
    if (!unsubscribed) {
        synchronized (this) {
            if (!unsubscribed) {
                if (subscriptions == null) {
                    subscriptions = new HashSet<Subscription>(4);
                }
                subscriptions.add(s);
                return;
            }
        }
    }
    s.unsubscribe();
}

由于unsubscribed = true，所以会执行s.unsubscribe();，直接解绑。