Package org.eclipse.jetty.client.api

Interface Request.Content

All Known Implementing Classes:
AbstractRequestContent, AsyncRequestContent, ByteBufferRequestContent, BytesRequestContent, FormRequestContent, InputStreamRequestContent, MultiPartRequestContent, OutputStreamRequestContent, PathRequestContent, ProxyServlet.ProxyInputStreamRequestContent, RequestContentAdapter, StringRequestContent
Enclosing interface:
Request
public static interface Request.Content

A reactive model to produce request content, similar to Flow.Publisher.

Implementations receive the content consumer via subscribe(Consumer, boolean), and return a Request.Content.Subscription as the link between producer and consumer.

Content producers must notify content to the consumer only if there is demand.

Content consumers can generate demand for content by invoking Request.Content.Subscription.demand().

Content production must follow this algorithm:

  • the first time content is demanded
    • when the content is not available => produce an empty content
    • when the content is available:
      • when emitInitialContent == false => produce an empty content
      • when emitInitialContent == true => produce the content
  • the second and subsequent times content is demanded
    • when the content is not available => do not produce content
    • when the content is available => produce the content
See Also:

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static interface 
    Request.Content.Consumer
    A reactive model to consume request content, similar to Flow.Subscriber.
    static interface 
    Request.Content.Subscription
    The link between a content producer and a content consumer.

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    fail(Throwable failure)
    Fails this request content, possibly failing and discarding accumulated content that was not demanded.
    default String
    getContentType()
     
    default long
    getLength()
     
    default boolean
    isReproducible()
    Whether this content producer can produce exactly the same content more than once.
    Request.Content.Subscription
    subscribe(Request.Content.Consumer consumer, boolean emitInitialContent)
    Initializes this content producer with the content consumer, and with the indication of whether initial content, if present, must be emitted upon the initial demand of content (to support delaying the send of the request content in case of Expect: 100-Continue when emitInitialContent is false).

  • Method Details

    • getContentType

      default String getContentType()
      Returns:
      the content type string such as "application/octet-stream" or "application/json;charset=UTF8", or null if no content type must be set

    • getLength

      default long getLength()
      Returns:
      the content length, if known, or -1 if the content length is unknown

    • isReproducible

      default boolean isReproducible()

      Whether this content producer can produce exactly the same content more than once.

      Implementations should return true only if the content can be produced more than once, which means that subscribe(Consumer, boolean) may be called again.

      The HttpClient implementation may use this method in particular cases where it detects that it is safe to retry a request that failed.

      Returns:
      whether the content can be produced more than once

    • subscribe

      Request.Content.Subscription subscribe(Request.Content.Consumer consumer, boolean emitInitialContent)

      Initializes this content producer with the content consumer, and with the indication of whether initial content, if present, must be emitted upon the initial demand of content (to support delaying the send of the request content in case of Expect: 100-Continue when emitInitialContent is false).

      Parameters:
      consumer - the content consumer to invoke when there is demand for content
      emitInitialContent - whether to emit initial content, if present
      Returns:
      the Subscription that links this producer to the consumer

    • fail

      default void fail(Throwable failure)

      Fails this request content, possibly failing and discarding accumulated content that was not demanded.

      The failure may be notified to the consumer at a later time, when the consumer demands for content.

      Typical failure: the request being aborted by user code, or idle timeouts.

      Parameters:
      failure - the reason of the failure