@Test public void immediateComposeCancelled() throws Exception { final ImmediateCompleted<To> future = new ImmediateCompleted<>(caller, to); doReturn(future).when(composeSupplier).get(); assertThat(base.thenComposeCancelledCancelled(composeSupplier), is(future)); }
Stage<T> thenComposeCancelledCancelled( final Supplier<? extends Stage<T>> fn ) { try { return fn.get(); } catch (final Exception e) { return new ImmediateFailed<>(caller, e); } }
AbstractImmediate implements Stage<T> { Stage<T> thenComposeCancelledCancelled( final Supplier<? extends Stage<T>> fn ) { try { return fn.get(); } catch (final Exception e) { return new ImmediateFailed<>(caller, e); } } }
AbstractImmediate implements Stage<T> { Stage<T> thenComposeCancelledCancelled( final Supplier<? extends Stage<T>> fn ) { try { return fn.get(); } catch (final Exception e) { return new ImmediateFailed<>(caller, e); } }  }
AbstractImmediate implements Stage<T> { Stage<T> thenComposeCancelledCancelled( final Supplier<? extends Stage<T>> fn ) { try { return fn.get(); } catch (final Exception e) { return new ImmediateFailed<>(caller, e); } }   }
AbstractImmediate implements Stage<T> { Stage<T> thenComposeCancelledCancelled( final Supplier<? extends Stage<T>> fn ) { try { return fn.get(); } catch (final Exception e) { return new ImmediateFailed<>(caller, e); } }    }