class Async::HTTP::Protocol::HTTP2::Stream
def send_body(body, task: Async::Task.current)
def send_body(body, task: Async::Task.current) # TODO Might need to stop this task when body is cancelled. @task = task.async do |subtask| subtask.annotate "Sending body: #{body.class}" @body = body window_updated end end