Update RealtimeConversationSession.cs

Author: shargon

src/Custom/RealtimeConversation/RealtimeConversationSession.cs

@@ -55,9 +55,9 @@ public virtual async Task SendInputAudioAsync(Stream audio, CancellationToken ca
             }
             _isSendingAudioStream = true;
         }
+        byte[] buffer = ArrayPool<byte>.Shared.Rent(1024 * 16);
         try
         {
-            byte[] buffer = ArrayPool<byte>.Shared.Rent(1024 * 16);
             while (true)
             {
                 int bytesRead = await audio.ReadAsync(buffer, 0, buffer.Length, cancellationToken).ConfigureAwait(false);
@@ -75,6 +75,7 @@ public virtual async Task SendInputAudioAsync(Stream audio, CancellationToken ca
         }
         finally
         {
+            ArrayPool<byte>.Shared.Return(buffer);
             using (await _audioSendSemaphore.AutoReleaseWaitAsync(cancellationToken).ConfigureAwait(false))
             {
                 _isSendingAudioStream = false;
@@ -93,9 +94,9 @@ public virtual void SendInputAudio(Stream audio, CancellationToken cancellationT
             }
             _isSendingAudioStream = true;
         }
+        byte[] buffer = ArrayPool<byte>.Shared.Rent(1024 * 16);
         try
         {
-            byte[] buffer = ArrayPool<byte>.Shared.Rent(1024 * 16);
             while (true)
             {
                 int bytesRead = audio.Read(buffer, 0, buffer.Length);
@@ -113,6 +114,7 @@ public virtual void SendInputAudio(Stream audio, CancellationToken cancellationT
         }
         finally
         {
+            ArrayPool<byte>.Shared.Return(buffer);
             using (_audioSendSemaphore.AutoReleaseWait(cancellationToken))
             {
                 _isSendingAudioStream = false;
@@ -349,4 +351,4 @@ public void Dispose()
     {
         WebSocket?.Dispose();
     }
-}
+}