@Test(expected = ExecutionException.class)
public void testExceptionWithMoreThanOneElement() throws InterruptedException, ExecutionException {

    Observable<String> obs = Observable.from("one", "two");
    Future<String> f = toFuture(obs);
    assertEquals("one", f.get());
    // we expect an exception since there are more than 1 element
}