adapt test to create 2 subscriptions as simultaneously as possible

Author: rose-a

src/GraphQL.Client/Websocket/GraphQLHttpWebSocket.cs

@@ -4,7 +4,6 @@
 using System.Net.Http;
 using System.Net.WebSockets;
 using System.Reactive;
-using System.Reactive.Concurrency;
 using System.Reactive.Disposables;
 using System.Reactive.Linq;
 using System.Reactive.Subjects;

tests/GraphQL.Integration.Tests/WebsocketTests/Base.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Concurrent;
+using System.Collections.Generic;
 using System.Diagnostics;
 using System.Linq;
 using System.Net.WebSockets;
@@ -257,8 +258,26 @@ public async void CanConnectTwoSubscriptionsSimultaneously()
             var observable2 = ChatClient.CreateSubscriptionStream<UserJoinedSubscriptionResult>(_subscriptionRequest2, callbackTester2.Invoke);
 
             Debug.WriteLine("subscribing...");
-            var messagesMonitor = observable1.Observe();
-            var joinedMonitor = observable2.Observe();
+            var blocker = new ManualResetEventSlim(false);
+            FluentTestObserver<GraphQLResponse<MessageAddedSubscriptionResult>> messagesMonitor = null;
+            FluentTestObserver<GraphQLResponse<UserJoinedSubscriptionResult>> joinedMonitor = null;
+
+            var tasks = new List<Task>
+            {
+                Task.Run(() =>
+                {
+                    blocker.Wait();
+                    messagesMonitor = observable1.Observe();
+                }),
+                Task.Run(() =>
+                {
+                    blocker.Wait();
+                    joinedMonitor = observable2.Observe();
+                })
+            };
+
+            blocker.Set();
+            await Task.WhenAll(tasks);
 
             await messagesMonitor.Should().PushAsync(1);
             messagesMonitor.RecordedMessages.Last().Data.MessageAdded.Content.Should().Be(InitialMessage.Content);