From a1ba60d9c69fdd122f036aa72a6f9d021cc8e22b Mon Sep 17 00:00:00 2001 From: cha0s Date: Wed, 9 Dec 2020 22:07:00 -0600 Subject: [PATCH] feat: promises --- packages/socket/src/client/socket.js | 8 ++++---- packages/socket/src/socket.js | 8 ++++---- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/packages/socket/src/client/socket.js b/packages/socket/src/client/socket.js index 1aca4aa..60e1875 100644 --- a/packages/socket/src/client/socket.js +++ b/packages/socket/src/client/socket.js @@ -94,22 +94,22 @@ export default class SocketClient extends decorate(Class) { return this.socket ? this.socket.id : undefined; } - static send(latus, socket, packetOrDehydrated) { + static send(latus, socket, packetOrDehydrated, method) { const packet = Array.isArray(packetOrDehydrated) ? this.hydrate(latus, packetOrDehydrated) : packetOrDehydrated; debug('sending packet %o', packet); const {id} = packet.constructor; - return socket.emitPromise(id, packet.data); + return socket[method](id, packet.data); } send(packet) { - return this.constructor.send(this.latus, this.socket, packet); + return this.constructor.send(this.latus, this.socket, packet, 'emitPromise'); } to(room) { return { - send: (packet) => this.constructor.send(this.latus, this.socket.to(room), packet), + send: (packet) => this.constructor.send(this.latus, this.socket.to(room), packet, 'emit'), }; } diff --git a/packages/socket/src/socket.js b/packages/socket/src/socket.js index 4795529..19fadb9 100644 --- a/packages/socket/src/socket.js +++ b/packages/socket/src/socket.js @@ -72,22 +72,22 @@ export default class ServerSocket extends decorate(Class) { return this.socket.rooms; } - static send(latus, socket, packetOrDehydrated) { + static send(latus, socket, packetOrDehydrated, method) { const packet = Array.isArray(packetOrDehydrated) ? this.hydrate(latus, packetOrDehydrated) : packetOrDehydrated; debug('sending packet %s(%o)', packet.constructor.name, packet.data); const {id} = packet.constructor; - return socket.emitPromise(id, packet.data); + return socket[method](id, packet.data); } send(packet) { - return this.constructor.send(this.latus, this.socket, packet); + return this.constructor.send(this.latus, this.socket, packet, 'emitPromise'); } to(room) { return { - send: (packet) => this.constructor.send(this.latus, this.socket.to(room), packet), + send: (packet) => this.constructor.send(this.latus, this.socket.to(room), packet, 'emit'), }; }