    @Test
    public void testGlobalSubscription() throws Exception {

        TestSubscriber<Place> testObserver = TestSubscriber.create();
        RxOkuki.onAnyPlace(okuki).subscribe(testObserver);
        verify(okuki).addGlobalListener(isA(GlobalListener.class));
        testObserver.unsubscribe();
        verify(okuki).removeGlobalListener(isA(GlobalListener.class));
    }