code: def stream_request(self, request, out_future):
          
          request.close_argstreams()
  
          def on_done(future):
              if future.exception() and out_future.running():
                  out_future.set_exc_info(future.exc_info())
              request.close_argstreams(force=True)
  
          stream_future = self._stream(request, self.request_message_factory)
          stream_future.add_done_callback(on_done)
          return stream_future
docs: send the given request and response is not required