code: public static <T> HttpResponseWriter streamingFrom(Publisher<T> publisher,
                                                         HttpHeaders headers, HttpHeaders trailingHeaders,
                                                         Function<T, HttpData> contentConverter) {
          final HttpResponseWriter writer = HttpResponse.streaming();
          publisher.subscribe(new StreamingSubscriber<>(writer, headers, trailingHeaders, contentConverter));
          return writer;
      }
docs: Returns a new {@link HttpResponseWriter} which sends a streaming response from the specified
  {@link Publisher}.
  
  @param publisher publishes objects
  @param headers to be written to the returned {@link HttpResponseWriter}
  @param trailingHeaders to be written to the returned {@link HttpResponseWriter}
  @param contentConverter converts the published objects into streaming contents of the response