Package io.micronaut.reactor.http.client

Interface ReactorStreamingHttpClient

All Superinterfaces:
AutoCloseable, Closeable, io.micronaut.http.client.HttpClient, io.micronaut.context.LifeCycle<io.micronaut.http.client.HttpClient>, ReactorHttpClient, io.micronaut.http.client.StreamingHttpClient
public interface ReactorStreamingHttpClient extends ReactorHttpClient, io.micronaut.http.client.StreamingHttpClient
Reactor variation of the StreamingHttpClient interface.
Since:
1.0.0
Author:
graemerocher

  • Field Summary

    Fields inherited from interface io.micronaut.http.client.HttpClient

    DEFAULT_ERROR_TYPE

  • Method Summary

    Modifier and Type
    Method
    Description
    static @NonNull ReactorStreamingHttpClient
    create(@Nullable URL url)
    Create a new ReactorStreamingHttpClient.
    static @NonNull ReactorStreamingHttpClient
    create(@Nullable URL url, @NonNull io.micronaut.http.client.HttpClientConfiguration configuration)
    Create a new ReactorStreamingHttpClient with the specified configuration.
    <I> reactor.core.publisher.Flux<io.micronaut.core.io.buffer.ByteBuffer<?>>
    dataStream(@NonNull io.micronaut.http.HttpRequest<I> request)
     
    <I> reactor.core.publisher.Flux<io.micronaut.http.HttpResponse<io.micronaut.core.io.buffer.ByteBuffer<?>>>
    exchangeStream(@NonNull io.micronaut.http.HttpRequest<I> request)
     
    <I> reactor.core.publisher.Flux<Map<String,Object>>
    jsonStream(@NonNull io.micronaut.http.HttpRequest<I> request)
     
    <I, O> reactor.core.publisher.Flux<O>
    jsonStream(@NonNull io.micronaut.http.HttpRequest<I> request, @NonNull io.micronaut.core.type.Argument<O> type)
     
    <I, O> reactor.core.publisher.Flux<O>
    jsonStream(@NonNull io.micronaut.http.HttpRequest<I> request, @NonNull Class<O> type)
     

    Methods inherited from interface io.micronaut.http.client.HttpClient

    refresh, toBlocking

    Methods inherited from interface io.micronaut.context.LifeCycle

    close, isRunning, start, stop

    Methods inherited from interface io.micronaut.reactor.http.client.ReactorHttpClient

    exchange, exchange, exchange, exchange, exchange, exchange, retrieve, retrieve, retrieve, retrieve, retrieve

    Methods inherited from interface io.micronaut.http.client.StreamingHttpClient

    dataStream, exchangeStream, jsonStream

  • Method Details

    • dataStream

      <I> reactor.core.publisher.Flux<io.micronaut.core.io.buffer.ByteBuffer<?>> dataStream(@NonNull @NonNull io.micronaut.http.HttpRequest<I> request)
      Specified by:
      dataStream in interface io.micronaut.http.client.StreamingHttpClient

    • exchangeStream

      <I> reactor.core.publisher.Flux<io.micronaut.http.HttpResponse<io.micronaut.core.io.buffer.ByteBuffer<?>>> exchangeStream(@NonNull @NonNull io.micronaut.http.HttpRequest<I> request)
      Specified by:
      exchangeStream in interface io.micronaut.http.client.StreamingHttpClient

    • jsonStream

      <I> reactor.core.publisher.Flux<Map<String,Object>> jsonStream(@NonNull @NonNull io.micronaut.http.HttpRequest<I> request)
      Specified by:
      jsonStream in interface io.micronaut.http.client.StreamingHttpClient

    • jsonStream

      <I, O> reactor.core.publisher.Flux<O> jsonStream(@NonNull @NonNull io.micronaut.http.HttpRequest<I> request, @NonNull @NonNull io.micronaut.core.type.Argument<O> type)
      Specified by:
      jsonStream in interface io.micronaut.http.client.StreamingHttpClient

    • jsonStream

      <I, O> reactor.core.publisher.Flux<O> jsonStream(@NonNull @NonNull io.micronaut.http.HttpRequest<I> request, @NonNull @NonNull Class<O> type)
      Specified by:
      jsonStream in interface io.micronaut.http.client.StreamingHttpClient

    • create

      @NonNull static @NonNull ReactorStreamingHttpClient create(@Nullable @Nullable URL url)
      Create a new ReactorStreamingHttpClient. Note that this method should only be used outside of the context of a Micronaut application. The returned ReactorStreamingHttpClient is not subject to dependency injection. The creator is responsible for closing the client to avoid leaking connections. Within a Micronaut application use Inject to inject a client instead.
      Parameters:
      url - The base URL
      Returns:
      The client
      Since:
      2.1.0

    • create

      @NonNull static @NonNull ReactorStreamingHttpClient create(@Nullable @Nullable URL url, @NonNull @NonNull io.micronaut.http.client.HttpClientConfiguration configuration)
      Create a new ReactorStreamingHttpClient with the specified configuration. Note that this method should only be used outside of the context of an application. Within Micronaut use Inject to inject a client instead
      Parameters:
      url - The base URL
      configuration - the client configuration
      Returns:
      The client
      Since:
      2.1.0