code: def write_body(self, chunk):
          
  
          if self.serializer:
              body = self.serializer.serialize_body(chunk)
          else:
              body = chunk
  
          if self.flushed:
              raise TChannelError("write operation invalid after flush call")
  
          if (self.argstreams[0].state != StreamState.completed and
                  self.argstreams[0].auto_close):
              self.argstreams[0].close()
          if (self.argstreams[1].state != StreamState.completed and
                  self.argstreams[1].auto_close):
              self.argstreams[1].close()
  
          return self.argstreams[2].write(body)
docs: Write to header.
  
          Note: whenever write_body is called, the header stream will be closed.
          write_header method is unavailable.
  
          :param chunk: content to write to body
  
          :except TChannelError:
              Raise TChannelError if the response's flush() has been called