@Test
public void testToFuture() throws InterruptedException, ExecutionException {

    Observable<String> obs = Observable.just("one");
    Future<String> f = toFuture(obs);
    assertEquals("one", f.get());
}