Changes API: How to subscribe to data subscription changes?

All subscription changes can be tracked by using forAllDataSubscriptions and forDataSubscription methods.

Syntax

IObservable<DataSubscriptionChangeNotification> forAllDataSubscriptions();

IObservable<DataSubscriptionChangeNotification> forDataSubscription(long id);

Example I

CleanCloseable subscription = store.
        changes()
        .forAllDataSubscriptions()
        .subscribe(Observers.create(new Action1<DataSubscriptionChangeNotification>() {
            @Override
            public void apply(DataSubscriptionChangeNotification change) {
                long subscriptionId = change.getId();

                switch (change.getType()) {
                    case SUBSCRIPTION_OPENED:
                        // do something
                        break;
                    case SUBSCRIPTION_RELEASED:
                        // do something
                        break;
                }
            }
        }));

Example II

int subscriptionId = 3;

CleanCloseable subscription2 = store.
        changes()
        .forDataSubscription(3)
        .subscribe(Observers.create(new Action1<DataSubscriptionChangeNotification>() {
            @Override
            public void apply(DataSubscriptionChangeNotification change) {
                long subscriptionId = change.getId();

                switch (change.getType()) {
                    case SUBSCRIPTION_OPENED:
                        // do something
                        break;
                    case SUBSCRIPTION_RELEASED:
                        // do something
                        break;
                }
            }
        }));