@Test public void testFromCompletionStage() { final CompletableFuture<Integer> cs = new CompletableFuture<>(); cs.complete(1); final Single<?> single = provider.fromCompletionStage(cs); assertEquals(1, single.blockingGet()); }
@Override public Single<?> fromCompletionStage(CompletionStage<?> completionStage) { return Single.fromFuture(completionStage.toCompletableFuture()); }
SingleProvider implements AsyncResponseProvider<Single<?>>, AsyncClientResponseProvider<Single<?>> { @Override public Single<?> fromCompletionStage(CompletionStage<?> completionStage) { return Single.fromFuture(completionStage.toCompletableFuture()); } }
SingleProvider implements AsyncResponseProvider<Single<?>>, AsyncClientResponseProvider<Single<?>> { @Override public Single<?> fromCompletionStage(CompletionStage<?> completionStage) { return Single.fromFuture(completionStage.toCompletableFuture()); }  }
SingleProvider implements AsyncResponseProvider<Single<?>>, AsyncClientResponseProvider<Single<?>> { @Override public Single<?> fromCompletionStage(CompletionStage<?> completionStage) { return Single.fromFuture(completionStage.toCompletableFuture()); }  @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 Single<?> fromCompletionStage(CompletionStage<?> completionStage) { return Single.fromFuture(completionStage.toCompletableFuture()); }  @Override CompletionStage<?> toCompletionStage(Single<?> asyncResponse); @Override Single<?> fromCompletionStage(CompletionStage<?> completionStage); @Override Single<?> fromCompletionStage(final Supplier<CompletionStage<?>> completionStageSupplier);  }