diff --git a/src/__mocks__/net.ts b/src/__mocks__/net.ts index e5342eb..08e50b1 100644 --- a/src/__mocks__/net.ts +++ b/src/__mocks__/net.ts @@ -65,7 +65,7 @@ export class Socket extends EventEmitter { this.onWrite(buff, encoding) } } - public end(): void { + public destroy(): void { this.setEnd() this.setClosed() } diff --git a/src/__tests__/hyperdeck.spec.ts b/src/__tests__/hyperdeck.spec.ts index c7beeaa..b19659a 100644 --- a/src/__tests__/hyperdeck.spec.ts +++ b/src/__tests__/hyperdeck.spec.ts @@ -104,7 +104,7 @@ describe('Hyperdeck', () => { expect(onConnection).toHaveBeenCalledTimes(1) expect(onDisconnection).toHaveBeenCalledTimes(0) - thisSocket?.end() + thisSocket?.destroy() await waitALittleBit() expect(hp.connected).toBeFalsy() diff --git a/src/hyperdeck.ts b/src/hyperdeck.ts index 9219d35..460e382 100644 --- a/src/hyperdeck.ts +++ b/src/hyperdeck.ts @@ -198,7 +198,7 @@ export class Hyperdeck extends EventEmitter { }) .catch((e) => { this._connected = false - this.socket.end() + this.socket.destroy() this.emit('error', 'connection failed', e) this._log('connection failed', e) @@ -259,7 +259,7 @@ export class Hyperdeck extends EventEmitter { } catch (e) { this._log('socket write failed', e) try { - this.socket.end() + this.socket.destroy() } catch (e2) { // ignore }