Class DelegateStreamedHttpResponse

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.HttpResponse, StreamedHttpMessage, StreamedHttpResponse, org.reactivestreams.Publisher<io.netty.handler.codec.http.HttpContent>

final class DelegateStreamedHttpResponse extends DelegateHttpResponse implements StreamedHttpResponse
  • Field Details

    • stream

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

    • DelegateStreamedHttpResponse

      public DelegateStreamedHttpResponse(io.netty.handler.codec.http.HttpResponse response, 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>