@Test public void testToCompletionStageCase() throws Exception { final Object actual = provider.toCompletionStage(Single.just(1)).toCompletableFuture().get(); assertEquals(1, actual); }
@Override public CompletionStage<?> toCompletionStage(Single<?> asyncResponse) { return new SingleAdaptor<>(asyncResponse); }
SingleProvider implements AsyncResponseProvider<Single<?>>, AsyncClientResponseProvider<Single<?>> { @Override public CompletionStage<?> toCompletionStage(Single<?> asyncResponse) { return new SingleAdaptor<>(asyncResponse); } }
SingleProvider implements AsyncResponseProvider<Single<?>>, AsyncClientResponseProvider<Single<?>> { @Override public CompletionStage<?> toCompletionStage(Single<?> asyncResponse) { return new SingleAdaptor<>(asyncResponse); }  }
SingleProvider implements AsyncResponseProvider<Single<?>>, AsyncClientResponseProvider<Single<?>> { @Override public CompletionStage<?> toCompletionStage(Single<?> asyncResponse) { return new SingleAdaptor<>(asyncResponse); }  @Override CompletionStage<?> toCompletionStage(Single<?> asyncResponse); @Override Single<?> fromCompletionStage(CompletionStage<?> completionStage); @Override Single<?> fromCompletionStage(final Supplier<CompletionStage<?>> completionStageSupplier); }
SingleProvider implements AsyncResponseProvider<Single<?>>, AsyncClientResponseProvider<Single<?>> { @Override public CompletionStage<?> toCompletionStage(Single<?> asyncResponse) { return new SingleAdaptor<>(asyncResponse); }  @Override CompletionStage<?> toCompletionStage(Single<?> asyncResponse); @Override Single<?> fromCompletionStage(CompletionStage<?> completionStage); @Override Single<?> fromCompletionStage(final Supplier<CompletionStage<?>> completionStageSupplier);  }