diff --git a/index.js b/index.js index 878cd74..9725aad 100644 --- a/index.js +++ b/index.js @@ -779,20 +779,20 @@ module.exports = class Protomux { } async popFree(id) { - await this.userData.syncProtomux("popFree", id); + await this.stream.syncProtomux("popFree", id); } async pushFree(id) { - await this.userData.syncProtomux("pushFree", id); + await this.stream.syncProtomux("pushFree", id); } async pushLocal(id) { - await this.userData.syncProtomux("pushLocal", id); + await this.stream.syncProtomux("pushLocal", id); } async pushRemote(id) { - await this.userData.syncProtomux("pushRemote", id); + await this.stream.syncProtomux("pushRemote", id); } async pullLocal() { - const ids = await this.userData.syncProtomux("pullLocal"); + const ids = await this.stream.syncProtomux("pullLocal"); ids.forEach((item) => { item = parseInt(item); @@ -802,13 +802,13 @@ module.exports = class Protomux { }); } async pullFree() { - const ids = await this.userData.syncProtomux("pullFree"); + const ids = await this.stream.syncProtomux("pullFree"); this._free = Array.from(new Set([...this._free, ...ids])); this._free = this._free.filter((item) => item !== null); } async pullRemote() { - const ids = await this.userData.syncProtomux("pullRemote"); + const ids = await this.stream.syncProtomux("pullRemote"); ids.forEach((item) => { item = parseInt(item);