code: func (conn *BytesConnectionStr) StopConsuming(topic string) error {
  	return conn.multiplexer.stopConsuming(topic, conn.name)
  }
docs: // StopConsuming cancels the previously created subscription for consuming the topic.