class HTTP::Response::IoBody

def stream!

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