From 0d9c3d8898b4398d82f029a2f4dc3c6fcf151a5d Mon Sep 17 00:00:00 2001 From: David Fowler Date: Sat, 7 Apr 2018 16:41:52 -0700 Subject: [PATCH] Buffer messages so we get a single outgoing request (#1898) --- .../LongPollingTransportTests.cs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/test/Microsoft.AspNetCore.SignalR.Client.Tests/LongPollingTransportTests.cs b/test/Microsoft.AspNetCore.SignalR.Client.Tests/LongPollingTransportTests.cs index e6826d3947..8da3342b4e 100644 --- a/test/Microsoft.AspNetCore.SignalR.Client.Tests/LongPollingTransportTests.cs +++ b/test/Microsoft.AspNetCore.SignalR.Client.Tests/LongPollingTransportTests.cs @@ -2,6 +2,7 @@ // Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information. using System; +using System.Buffers; using System.Collections.Generic; using System.IO.Pipelines; using System.Net; @@ -326,8 +327,9 @@ namespace Microsoft.AspNetCore.SignalR.Client.Tests // Start the transport await longPollingTransport.StartAsync(new Uri("http://fakeuri.org"), TransferFormat.Binary); - await longPollingTransport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello")); - await longPollingTransport.Output.WriteAsync(Encoding.UTF8.GetBytes("World")); + longPollingTransport.Output.Write(Encoding.UTF8.GetBytes("Hello")); + longPollingTransport.Output.Write(Encoding.UTF8.GetBytes("World")); + await longPollingTransport.Output.FlushAsync(); longPollingTransport.Output.Complete();