diff --git a/Hermes/Socket/HermesSocketClient.cs b/Hermes/Socket/HermesSocketClient.cs index ff1d2e6..9064ce9 100644 --- a/Hermes/Socket/HermesSocketClient.cs +++ b/Hermes/Socket/HermesSocketClient.cs @@ -62,7 +62,7 @@ namespace TwitchChatTTS.Hermes.Socket } - public async Task Connect() + public override async Task Connect() { lock (_lock) { @@ -263,7 +263,7 @@ namespace TwitchChatTTS.Hermes.Socket _logger.Warning("Hermes websocket client disconnected."); _heartbeatTimer.Enabled = false; - await Reconnect(_backoff, async () => await Connect()); + await Reconnect(_backoff); }; } diff --git a/OBS/Socket/OBSSocketClient.cs b/OBS/Socket/OBSSocketClient.cs index 0197f4a..f06d7c6 100644 --- a/OBS/Socket/OBSSocketClient.cs +++ b/OBS/Socket/OBSSocketClient.cs @@ -84,7 +84,7 @@ namespace TwitchChatTTS.OBS.Socket _sourceIds.Clear(); } - public async Task Connect() + public override async Task Connect() { if (string.IsNullOrWhiteSpace(URL)) { diff --git a/Seven/Socket/SevenSocketClient.cs b/Seven/Socket/SevenSocketClient.cs index 35bc68a..9d37567 100644 --- a/Seven/Socket/SevenSocketClient.cs +++ b/Seven/Socket/SevenSocketClient.cs @@ -85,7 +85,7 @@ namespace TwitchChatTTS.Seven.Socket URL = $"{SevenApiClient.WEBSOCKET_URL}@emote_set.*"; } - public async Task Connect() + public override async Task Connect() { if (string.IsNullOrEmpty(URL)) { @@ -137,7 +137,7 @@ namespace TwitchChatTTS.Seven.Socket Task.Run(async () => { - await Reconnect(_backoff, async () => await Connect()); + await Reconnect(_backoff); await Task.Delay(TimeSpan.FromMilliseconds(500)); if (Connected && ConnectionDetails?.SessionId != null) diff --git a/Twitch/Socket/TwitchWebsocketClient.cs b/Twitch/Socket/TwitchWebsocketClient.cs index 30e0bcf..441ed2f 100644 --- a/Twitch/Socket/TwitchWebsocketClient.cs +++ b/Twitch/Socket/TwitchWebsocketClient.cs @@ -111,7 +111,7 @@ namespace TwitchChatTTS.Twitch.Socket }; } - public async Task Connect() + public override async Task Connect() { if (string.IsNullOrWhiteSpace(URL)) { @@ -123,7 +123,7 @@ namespace TwitchChatTTS.Twitch.Socket await ConnectAsync(URL); } - public async Task Reconnect() => await Reconnect(_backoff, async () => await Connect()); + public async Task Reconnect() => await Reconnect(_backoff); public void Identify(string sessionId) {