如何取消订阅PublishSubject和BehaviorSubject？

Question

下的subjects包你有这样的类PublishSubject和BehaviorSubject我想可以被描述为一些可用的样品Observables.

如何取消订阅这些主题？没有unsubscribe方法和调用onCompleted完全结束了Observable吗？

Answer 1

主体是一个Subject和Observable同时,它可以像普通的可观察者一样取消订阅.使主题变得特别的是它是可观察者和观察者之间的桥梁.它可以通过重新发送它来传递它观察到的物品,它也可以发出新物品.由于承诺是期货,所以主题是可观察的.

这里是受试者家庭的简要描述:

AsyncSubject:仅发出源Observable的最后一个值

BehaviorSubject:当观察者订阅它时,发出最近发出的项和源Observable的所有后续项

PublishSubject:在订阅时发出源Observable的所有后续项

ReplaySubject:发出源Observable的所有项目,无论订阅者何时订阅.

在官方文档提供了一些好的大理石图这使得它更容易理解

Answer 2

主题基本上是两观测量和观察员.

Observable本质上是一个具有Observer并返回订阅的函数的东西.因此,例如,给定简单的可观察量:

    Observable<Integer> observable = Observable.create(new Observable.OnSubscribeFunc<Integer>() {
        @Override
        public Subscription onSubscribe(Observer<? super Integer> observer) {
            observer.onNext(3);
            observer.onNext(2);
            observer.onNext(1);
            observer.onCompleted();

            return Subscriptions.empty();
        }
    });

在这里我们会订阅它,为每个整数打印一行:

    Subscription sub = observable.subscribe(new Action1<Integer>() {
        @Override
        public void call(Integer integer) {
            System.out.println(integer);
        }
    });

您可以通过致电取消订阅上述内容sub.unsubscribe().

这是一个PublishSubject,大致相同:

    PublishSubject<Integer> publishSubject = PublishSubject.create();
    Subscription subscription = publishSubject.subscribe(new Action1<Integer>() {
        @Override
        public void call(Integer integer) {
            System.out.println(integer);
        }
    });

    publishSubject.onNext(3);
    publishSubject.onNext(2);
    publishSubject.onNext(1);

您可以通过调用以相同的方式取消订阅subscription.unsubscribe().

Answer 3

您可以使用任何多种方法订阅的所有Subjects扩展.调用任何方法都会返回一个.Observablesubscribe(...)subscribe(...)Subscription

Subscription subscription = anySubject.subscribe(...);

如果要停止从主题中侦听事件,请使用此subscription实例的unsubscribe()方法.

subscription.unsubscribe();