RxMock.java 文件源码

private AddUnsubscribe clearOnUnsubscribe(final Object observable) {
    return new AddUnsubscribe(
            BooleanSubscription.create(
                    new Action0() {
                        @Override
                        public void call() {
                            mapSubject.get(observable).first.clear();
                        }
                    }
            )
    );
}