diff --git a/src/lib/src/data-access/websocket/service.ts b/src/lib/src/data-access/websocket/service.ts index 4cfad25..14c99e7 100644 --- a/src/lib/src/data-access/websocket/service.ts +++ b/src/lib/src/data-access/websocket/service.ts @@ -60,13 +60,13 @@ export class WebSocketService extends Base } /** @inheritdoc */ - public subscribeToChannel(channelName: TChannelName, onEvent: WebSocketListener): void { + public override subscribeToChannel(channelName: TChannelName, onEvent: WebSocketListener): void { super.subscribeToChannel(channelName, onEvent); this.addEventHandlerToPusher(channelName); } /** @inheritdoc */ - public async unsubscribeFromChannel(channelName: TChannelName, onEvent: WebSocketListener): Promise { + public override async unsubscribeFromChannel(channelName: TChannelName, onEvent: WebSocketListener): Promise { super.unsubscribeFromChannel(channelName, onEvent); if (!this.channels[channelName] || this.channels[channelName].length === 0) { diff --git a/src/lib/src/data-access/websocket/service.web.ts b/src/lib/src/data-access/websocket/service.web.ts index dcb12c9..3bc3965 100644 --- a/src/lib/src/data-access/websocket/service.web.ts +++ b/src/lib/src/data-access/websocket/service.web.ts @@ -55,7 +55,7 @@ export class WebSocketService extends Base } /** @inheritdoc */ - public subscribeToChannel(channelName: TChannelName, onEvent: WebSocketListener): void { + public override subscribeToChannel(channelName: TChannelName, onEvent: WebSocketListener): void { if (!this.pusher) { return; } @@ -68,7 +68,7 @@ export class WebSocketService extends Base } /** @inheritdoc */ - public unsubscribeFromChannel(channelName: TChannelName, onEvent: WebSocketListener): void { + public override unsubscribeFromChannel(channelName: TChannelName, onEvent: WebSocketListener): void { if (!this.pusher) { return; }