refactor: 更改申请缓存区代码

ArgoZhang · ArgoZhang · commit 6ea1b2539e87 · 2025-06-19T14:32:41.000+08:00
diff --git a/src/BootstrapBlazor/Services/TcpSocket/DefaultTcpSocketClient.cs b/src/BootstrapBlazor/Services/TcpSocket/DefaultTcpSocketClient.cs
@@ -112,8 +112,6 @@ public async Task<bool> SendAsync(Memory<byte> data, CancellationToken token = d
 
     private async Task ReceiveAsync()
     {
-        using var block = MemoryPool<byte>.Shared.Rent(ReceiveBufferSize);
-        var buffer = block.Memory;
         _receiveCancellationTokenSource ??= new();
         while (_receiveCancellationTokenSource is { IsCancellationRequested: false })
         {
@@ -124,6 +122,8 @@ private async Task ReceiveAsync()
 
             try
             {
+                using var block = MemoryPool<byte>.Shared.Rent(ReceiveBufferSize);
+                var buffer = block.Memory;
                 var stream = _client.GetStream();
                 var len = await stream.ReadAsync(buffer, _receiveCancellationTokenSource.Token);
                 if (len == 0)

Original file line number	Diff line number	Diff line change
`@@ -112,8 +112,6 @@ public async Task<bool> SendAsync(Memory<byte> data, CancellationToken token = d`
`112`	`112`
`113`	`113`	`private async Task ReceiveAsync()`
`114`	`114`	`{`
`115`		`- using var block = MemoryPool<byte>.Shared.Rent(ReceiveBufferSize);`
`116`		`- var buffer = block.Memory;`
`117`	`115`	`_receiveCancellationTokenSource ??= new();`
`118`	`116`	`while (_receiveCancellationTokenSource is { IsCancellationRequested: false })`
`119`	`117`	`{`
`@@ -124,6 +122,8 @@ private async Task ReceiveAsync()`
`124`	`122`
`125`	`123`	`try`
`126`	`124`	`{`
	`125`	`+ using var block = MemoryPool<byte>.Shared.Rent(ReceiveBufferSize);`
	`126`	`+ var buffer = block.Memory;`
`127`	`127`	`var stream = _client.GetStream();`
`128`	`128`	`var len = await stream.ReadAsync(buffer, _receiveCancellationTokenSource.Token);`
`129`	`129`	`if (len == 0)`