From f6f0007c120df84ca170dd406e71cb45d701ec19 Mon Sep 17 00:00:00 2001 From: BrennanConroy Date: Mon, 3 Apr 2017 11:45:00 -0700 Subject: [PATCH] React to CoreFx byte[] slice --- .../EndToEndTests.cs | 2 +- .../WebSocketConnectionTests.ReceiveAsync.cs | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/test/Microsoft.AspNetCore.SignalR.Tests/EndToEndTests.cs b/test/Microsoft.AspNetCore.SignalR.Tests/EndToEndTests.cs index aa80e4099e..782f3baa93 100644 --- a/test/Microsoft.AspNetCore.SignalR.Tests/EndToEndTests.cs +++ b/test/Microsoft.AspNetCore.SignalR.Tests/EndToEndTests.cs @@ -57,7 +57,7 @@ namespace Microsoft.AspNetCore.SignalR.Tests var buffer = new ArraySegment(new byte[1024]); var result = await ws.ReceiveAsync(buffer, CancellationToken.None); - Assert.Equal(bytes, buffer.Array.Slice(0, message.Length).ToArray()); + Assert.Equal(bytes, buffer.Array.AsSpan().Slice(0, message.Length).ToArray()); await ws.CloseAsync(WebSocketCloseStatus.Empty, "", CancellationToken.None); } diff --git a/test/Microsoft.Extensions.WebSockets.Internal.Tests/WebSocketConnectionTests.ReceiveAsync.cs b/test/Microsoft.Extensions.WebSockets.Internal.Tests/WebSocketConnectionTests.ReceiveAsync.cs index 79e38d7eaf..5d3b2d9e13 100644 --- a/test/Microsoft.Extensions.WebSockets.Internal.Tests/WebSocketConnectionTests.ReceiveAsync.cs +++ b/test/Microsoft.Extensions.WebSockets.Internal.Tests/WebSocketConnectionTests.ReceiveAsync.cs @@ -64,13 +64,13 @@ namespace Microsoft.Extensions.WebSockets.Internal.Tests var result = await RunReceiveTest( producer: async (channel, cancellationToken) => { - await channel.WriteAsync(new byte[] { 0x02, 0x05 }.Slice()).OrTimeout(); + await channel.WriteAsync(new byte[] { 0x02, 0x05 }.AsSpan()).OrTimeout(); await Task.Yield(); - await channel.WriteAsync(new byte[] { 0xDE, 0xAD, 0xBE, 0xEF, 0xAB, 0x80, 0x05 }.Slice()).OrTimeout(); + await channel.WriteAsync(new byte[] { 0xDE, 0xAD, 0xBE, 0xEF, 0xAB, 0x80, 0x05 }.AsSpan()).OrTimeout(); await Task.Yield(); - await channel.WriteAsync(new byte[] { 0xDE, 0xAD, 0xBE, 0xEF }.Slice()).OrTimeout(); + await channel.WriteAsync(new byte[] { 0xDE, 0xAD, 0xBE, 0xEF }.AsSpan()).OrTimeout(); await Task.Yield(); - await channel.WriteAsync(new byte[] { 0xAB }.Slice()).OrTimeout(); + await channel.WriteAsync(new byte[] { 0xAB }.AsSpan()).OrTimeout(); await Task.Yield(); }); @@ -178,7 +178,7 @@ namespace Microsoft.Extensions.WebSockets.Internal.Tests var result = await RunReceiveTest( producer: async (channel, cancellationToken) => { - await channel.WriteAsync(rawFrame.Slice()).OrTimeout(); + await channel.WriteAsync(rawFrame.AsSpan()).OrTimeout(); }); var frames = result.Received; Assert.Equal(1, frames.Count);