In RxJava1, i’ve seen people doing it this way: `...

# rx

[ubu]

In RxJava1, i’ve seen people doing it this way:

subscriber.add(Subscriptions.create(new Action0() {
                    @Override
                    public void call() {
                        ref.removeEventListener(listener);
                    }
                }));