code: func (pdb *BytesBrokerWatcherRedis) NewTxn() keyval.BytesTxn {
  	if pdb.delegate.closed {
  		pdb.Error("NewTxn() called on a closed connection")
  		return nil
  	}
  	pdb.Debug("NewTxn()")
  
  	return &Txn{db: pdb.delegate, ops: []op{}, addPrefix: pdb.addPrefix}
  }
docs: // NewTxn creates new transaction. Prefix will be prepended to the key argument.