fix tests locally

Author: rose-a

src/GraphQL.Client/Websocket/GraphQLHttpWebSocket.cs

@@ -502,7 +502,7 @@ private async Task<WebsocketMessageWrapper> ReceiveWebsocketMessagesAsync() {
 				if (webSocketReceiveResult.MessageType == WebSocketMessageType.Text) {
 					var response = await Options.JsonSerializer.DeserializeToWebsocketResponseWrapperAsync(ms);
 					response.MessageBytes = ms.ToArray();
-					Debug.WriteLine($"{response.MessageBytes.Length} bytes received on websocket {clientWebSocket.GetHashCode()} (thread {Thread.CurrentThread.ManagedThreadId})...");
+					Debug.WriteLine($"{response.MessageBytes.Length} bytes received for id {response.Id} on websocket {clientWebSocket.GetHashCode()} (thread {Thread.CurrentThread.ManagedThreadId})...");
 					return response;
 				}
 				else {

tests/GraphQL.Client.Tests.Common/Helpers/ObservableTester.cs

@@ -13,7 +13,6 @@ public class ObservableTester<TSubscriptionPayload> : IDisposable {
 		private readonly ManualResetEventSlim updateReceived = new ManualResetEventSlim();
 		private readonly ManualResetEventSlim completed = new ManualResetEventSlim();
 		private readonly ManualResetEventSlim error = new ManualResetEventSlim();
-		private readonly EventLoopScheduler subscriptionScheduler = new EventLoopScheduler();
 		private readonly EventLoopScheduler observeScheduler = new EventLoopScheduler();
 
 		/// <summary>
@@ -37,13 +36,11 @@ public class ObservableTester<TSubscriptionPayload> : IDisposable {
 		/// </summary>
 		/// <param name="observable">the <see cref="IObservable{T}"/> under test</param>
 		public ObservableTester(IObservable<TSubscriptionPayload> observable) {
-			subscriptionScheduler.Schedule(() =>
-				Debug.WriteLine($"Subscription scheduler thread id: {Thread.CurrentThread.ManagedThreadId}"));
 
 			observeScheduler.Schedule(() =>
 				Debug.WriteLine($"Observe scheduler thread id: {Thread.CurrentThread.ManagedThreadId}"));
 
-			subscription = observable.SubscribeOn(subscriptionScheduler).ObserveOn(observeScheduler).Subscribe(
+			subscription = observable.ObserveOn(observeScheduler).Subscribe(
 				obj => {
 					Debug.WriteLine($"observable tester {GetHashCode()}: payload received");
 					LastPayload = obj;
@@ -70,7 +67,6 @@ private void Reset() {
 		/// <inheritdoc />
 		public void Dispose() {
 			subscription?.Dispose();
-			subscriptionScheduler.Dispose();
 			observeScheduler.Dispose();
 		}
 

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

@@ -233,36 +233,38 @@ public async void CanConnectTwoSubscriptionsSimultaneously() {
 			var observable2 = ChatClient.CreateSubscriptionStream<UserJoinedSubscriptionResult>(SubscriptionRequest2, callbackTester2.Invoke);
 
 			Debug.WriteLine("subscribing...");
-			var tester = observable1.Monitor();
-			var tester2 = observable2.Monitor();
+			var messagesMonitor = observable1.Monitor();
+			var joinedMonitor = observable2.Monitor();
 
-			tester.Should().HaveReceivedPayload().Which.Data.MessageAdded.Content.Should().Be(InitialMessage.Content);
+			messagesMonitor.Should().HaveReceivedPayload().Which.Data.MessageAdded.Content.Should().Be(InitialMessage.Content);
 
 			const string message1 = "Hello World";
 			var response = await ChatClient.AddMessageAsync(message1);
 			response.Data.AddMessage.Content.Should().Be(message1);
-			tester.Should().HaveReceivedPayload()
+			messagesMonitor.Should().HaveReceivedPayload()
 				.Which.Data.MessageAdded.Content.Should().Be(message1);
+			joinedMonitor.Should().NotHaveReceivedPayload();
 
 			var joinResponse = await ChatClient.JoinDeveloperUser();
 			joinResponse.Data.Join.DisplayName.Should().Be("developer", "because that's the display name of user \"1\"");
 
-			var payload = tester2.Should().HaveReceivedPayload().Subject;
+			var payload = joinedMonitor.Should().HaveReceivedPayload().Subject;
 			payload.Data.UserJoined.Id.Should().Be("1", "because that's the id we sent with our mutation request");
 			payload.Data.UserJoined.DisplayName.Should().Be("developer", "because that's the display name of user \"1\"");
+			messagesMonitor.Should().NotHaveReceivedPayload();
 
 			Debug.WriteLine("disposing subscription...");
-			tester2.Dispose();
+			joinedMonitor.Dispose();
 
 			const string message3 = "lorem ipsum dolor si amet";
 			response = await ChatClient.AddMessageAsync(message3);
 			response.Data.AddMessage.Content.Should().Be(message3);
-			tester.Should().HaveReceivedPayload()
+			messagesMonitor.Should().HaveReceivedPayload()
 				.Which.Data.MessageAdded.Content.Should().Be(message3);
 
 			// disposing the client should complete the subscription
 			ChatClient.Dispose();
-			tester.Should().HaveCompleted();
+			messagesMonitor.Should().HaveCompleted();
 		}