fix async

Author: Jicheng Lu

src/Plugins/BotSharp.Plugin.ChatHub/ChatStreamMiddleware.cs

@@ -92,15 +92,19 @@ private async Task HandleWebSocket(IServiceProvider services, string agentId, st
             }
         }
 
-        _session?.Disconnect();
-        _session?.Dispose();
+
+        await _session.Disconnect();
+        _session.Dispose();
     }
 
     private async Task ConnectToModel(IRealtimeHub hub, WebSocket webSocket)
     {
         await hub.ConnectToModel(async data =>
         {
-            await _session.SendEvent(data);
+            if (_session != null)
+            {
+                await _session.SendEvent(data);
+            }
         });
     }
 

src/Plugins/BotSharp.Plugin.OpenAI/Providers/Realtime/RealTimeCompletionProvider.cs

@@ -52,10 +52,12 @@ public async Task Connect(
         {
             _session.Dispose();
         }
+
         _session = new LlmRealtimeSession(_services, new ChatSessionOptions
         {
             JsonOptions = _botsharpOptions.JsonSerializerOptions
         });
+
         await _session.ConnectAsync(
             uri: new Uri($"wss://api.openai.com/v1/realtime?model={_model}"),
             headers: new Dictionary<string, string>
@@ -79,7 +81,11 @@ await _session.ConnectAsync(
 
     public async Task Disconnect()
     {
-        _session?.Disconnect();
+        if (_session != null)
+        {
+            await _session.Disconnect();
+            _session.Dispose();
+        }
     }
 
     public async Task AppenAudioBuffer(string message)
@@ -139,7 +145,8 @@ await SendEventToModel(new
         });
     }
 
-    private async Task ReceiveMessage(RealtimeHubConnection conn,
+    private async Task ReceiveMessage(
+        RealtimeHubConnection conn,
         Action onModelReady,
         Action<string, string> onModelAudioDeltaReceived,
         Action onModelAudioResponseDone,