Class DelegateStreamedHttpRequest

All Implemented Interfaces:
io.netty.handler.codec.DecoderResultProvider, io.netty.handler.codec.http.HttpMessage, io.netty.handler.codec.http.HttpObject, io.netty.handler.codec.http.HttpRequest, StreamedHttpMessage, StreamedHttpRequest, org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent>

final class DelegateStreamedHttpRequest extends DelegateHttpRequest implements StreamedHttpRequest
  • Field Details

    • stream

      private final org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent> stream
  • Constructor Details

    • DelegateStreamedHttpRequest

      public DelegateStreamedHttpRequest(io.netty.handler.codec.http.HttpRequest request, org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent> stream)
  • Method Details

    • subscribe

      public void subscribe(org.reactivestreams.Subscriber<? super io.netty.handler.codec.http.HttpContent> subscriber)
      Specified by:
      subscribe in interface org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent>