@Test public void testFromCompletionStage() { final CompletableFuture<Integer> cs = new CompletableFuture<>(); cs.complete(1); final Mono<?> mono = provider.fromCompletionStage(cs); assertEquals(1, mono.block()); }
@Override public Mono<?> fromCompletionStage(final CompletionStage<?> completionStage) { return Mono.fromFuture(completionStage.toCompletableFuture()); }
MonoProvider implements AsyncResponseProvider<Mono<?>>, AsyncClientResponseProvider<Mono<?>> { @Override public Mono<?> fromCompletionStage(final CompletionStage<?> completionStage) { return Mono.fromFuture(completionStage.toCompletableFuture()); } }
MonoProvider implements AsyncResponseProvider<Mono<?>>, AsyncClientResponseProvider<Mono<?>> { @Override public Mono<?> fromCompletionStage(final CompletionStage<?> completionStage) { return Mono.fromFuture(completionStage.toCompletableFuture()); }  }
MonoProvider implements AsyncResponseProvider<Mono<?>>, AsyncClientResponseProvider<Mono<?>> { @Override public Mono<?> fromCompletionStage(final CompletionStage<?> completionStage) { return Mono.fromFuture(completionStage.toCompletableFuture()); }  @Override CompletionStage<?> toCompletionStage(final Mono<?> asyncResponse); @Override Mono<?> fromCompletionStage(final CompletionStage<?> completionStage); @Override Mono<?> fromCompletionStage(final Supplier<CompletionStage<?>> completionStageSupplier); }
MonoProvider implements AsyncResponseProvider<Mono<?>>, AsyncClientResponseProvider<Mono<?>> { @Override public Mono<?> fromCompletionStage(final CompletionStage<?> completionStage) { return Mono.fromFuture(completionStage.toCompletableFuture()); }  @Override CompletionStage<?> toCompletionStage(final Mono<?> asyncResponse); @Override Mono<?> fromCompletionStage(final CompletionStage<?> completionStage); @Override Mono<?> fromCompletionStage(final Supplier<CompletionStage<?>> completionStageSupplier);  }