code: func (ev *msgEventer) Close() error {
  	if v, ok := ev.MsgReadWriter.(io.Closer); ok {
  		return v.Close()
  	}
  	return nil
  }
docs: // Close closes the underlying MsgReadWriter if it implements the io.Closer
  // interface