From 1387b060a4e37ad5f21db2863d43d0aa33cdd619 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Thu, 6 Apr 2023 17:29:29 -0400 Subject: [PATCH] use this.stream --- index.js | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) 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);