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 Detail

      • 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