class HTTP::Response::Body

Assert that the body is actively being streamed

def stream!
  fail StateError, "body has already been consumed" if @streaming == false
  @streaming = true
end