RxGoro { public Scheduler scheduler(String queueName) { return new GoroScheduler(goro, queueName); } RxGoro(final Goro goro); Goro wrappedGoro(); Observable<T> schedule(final Callable<T> task); Observable<T> schedule(final String queue, final Callable<T> task); Scheduler scheduler(String queueName); Scheduler scheduler();  }
@Test public void unsubscribe() { TestSubscriber<String> subscriber = new TestSubscriber<>(); Observable.just("ok") .subscribeOn(rxGoro.scheduler()) .subscribe(subscriber) .unsubscribe(); queues.executeAll(); subscriber.assertNoErrors(); subscriber.assertNoValues(); subscriber.assertNotCompleted(); }