Interface AsyncClientResponseProvider<T>

All Known Implementing Classes:
MonoProvider, SingleProvider
public interface AsyncClientResponseProvider<T>
Used to turn a CompletionStage into another reactive class. Can be used for implementing RxInvokers for other suitable classes.

  • Method Details

    • fromCompletionStage

      T fromCompletionStage(CompletionStage<?> completionStage)
      Turns CompletionStage to a reactive type.
      Parameters:
      completionStage - The CompletionStage that will produce a value.
      Returns:
      T reactive type

    • fromCompletionStage

      T fromCompletionStage(Supplier<CompletionStage<?>> completionStageSupplier)
      Turns CompletionStage to a reactive type in a deferred fashion. For instance, in the case of Rx or Reactor, the Supplier.get() will only be called when subscription happens.
      Parameters:
      completionStageSupplier - The Supplier of a CompletionStage that will produce a value. This allows lazy triggering of future-based APIs.
      Returns:
      T reactive type