fixup! Dispose CTS when the Stream is claimed or timeout occurs

clegoz · clegoz · commit 9bcfe203df2c · 2024-12-30T02:32:43.000+03:00
diff --git a/src/Components/Server/src/Circuits/RemoteJSRuntime.cs b/src/Components/Server/src/Circuits/RemoteJSRuntime.cs
@@ -153,7 +153,7 @@ protected override void ReceiveByteArray(int id, byte[] data)
     protected override async Task TransmitStreamAsync(long streamId, DotNetStreamReference dotNetStreamReference)
     {
         var cancelableStreamReference = new CancelableDotNetStreamReference(dotNetStreamReference);
-        if (_pendingDotNetToJSStreams.TryAdd(streamId, cancelableStreamReference))
+        if (!_pendingDotNetToJSStreams.TryAdd(streamId, cancelableStreamReference))
         {
             throw new ArgumentException($"The stream {streamId} is already pending.");
         }

Original file line number	Diff line number	Diff line change
`@@ -153,7 +153,7 @@ protected override void ReceiveByteArray(int id, byte[] data)`
`153`	`153`	`protected override async Task TransmitStreamAsync(long streamId, DotNetStreamReference dotNetStreamReference)`
`154`	`154`	`{`
`155`	`155`	`var cancelableStreamReference = new CancelableDotNetStreamReference(dotNetStreamReference);`
`156`		`- if (_pendingDotNetToJSStreams.TryAdd(streamId, cancelableStreamReference))`
	`156`	`+ if (!_pendingDotNetToJSStreams.TryAdd(streamId, cancelableStreamReference))`
`157`	`157`	`{`
`158`	`158`	`throw new ArgumentException($"The stream {streamId} is already pending.");`
`159`	`159`	`}`