RxGoro { public <T> Observable<T> schedule(final Callable<T> task) { return schedule(Goro.DEFAULT_QUEUE, task); } 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 schedule() { TestSubscriber<String> subscriber = new TestSubscriber<>(); Observable.just("ok") .subscribeOn(rxGoro.scheduler("test")) .subscribe(subscriber); subscriber.assertNoValues(); subscriber.assertNotCompleted(); queues.executeAll(); subscriber.assertNoErrors(); subscriber.assertCompleted(); subscriber.assertValue("ok"); }