class HTTP::Response::Body

def stream!

Assert that the body is actively being streamed 
def stream!
  raise StateError, "body has already been consumed" if @streaming == false
  @streaming = true
end