code: func (db *ProtoWrapper) NewWatcher(prefix string) keyval.ProtoWatcher {
  	return &protoWatcher{db.broker.NewWatcher(prefix), db.serializer}
  }
docs: // NewWatcher creates a new instance of the proxy that shares the underlying
  // connection and allows subscribing for watching of the changes.