43ServerRpc = new JsonRpc(new HeaderDelimitedMessageHandler(serverStream, serverStream, new SystemTextJsonFormatter()));

32registry.AddIntegrationHost(connection.ServerRpc); 40Assert.True(registry.MarkHostUnavailable(connection.ServerRpc)); 41Assert.True(registry.MarkHostUnavailable(connection.ServerRpc)); 66registry.AddIntegrationHost(connection.ServerRpc); 75await connection.ServerRpc.Completion.WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken); 87Assert.All(states, state => Assert.Equal(connection.ServerRpc.GetHashCode(), state["Host"])); 110registry.AddIntegrationHost(connection.ServerRpc); 125registry.AddIntegrationHost(connection.ServerRpc); 162registry.AddIntegrationHost(connection.ServerRpc); 196registry.AddIntegrationHost(integration.ServerRpc); 201var result = await registry.InvokeGuestCallbackAsync(integration.ServerRpc, relayId, 205guest.ServerRpc, relayId, null, TestContext.Current.CancellationToken)); 209integration.ServerRpc, relayId, null, TestContext.Current.CancellationToken)); 225registry.AddIntegrationHost(integration.ServerRpc); 234await integration.ServerRpc.Completion.WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken); 258registry.AddIntegrationHost(integration.ServerRpc); 276await integration.ServerRpc.Completion.WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken); 310guestInvoker.SetConnection(guest.ServerRpc); 311registry.AddIntegrationHost(integration.ServerRpc); 315var invocation = registry.InvokeGuestCallbackAsync(integration.ServerRpc, relayId, null, TestContext.Current.CancellationToken); 368guestInvoker.SetConnection(guest.ServerRpc); 370registry.AddIntegrationHost("integration", integration.ServerRpc, integration.CallbackInvoker); 376var invocation = registry.InvokeGuestCallbackAsync(integration.ServerRpc, relayId, null, TestContext.Current.CancellationToken); 403await integration.ServerRpc.Completion.WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken); 404await guest.ServerRpc.Completion.WaitAsync(TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken); 406Assert.True(registry.MarkHostUnavailable(integration.ServerRpc)); 409integration.ServerRpc, replacement.ServerRpc, TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken)); 424Assert.Throws<InvalidOperationException>(() => registry.AddIntegrationHost("unknown", connection.ServerRpc, connection.CallbackInvoker)); 426registry.AddIntegrationHost("attempt", connection.ServerRpc, connection.CallbackInvoker); 427Assert.Same(connection.ServerRpc, await registration); 428Assert.Throws<InvalidOperationException>(() => registry.AddIntegrationHost("attempt", connection.ServerRpc, connection.CallbackInvoker)); 442Assert.Throws<InvalidOperationException>(() => registry.AddIntegrationHost("old", connection.ServerRpc, connection.CallbackInvoker)); 444registry.AddIntegrationHost("replacement", connection.ServerRpc, connection.CallbackInvoker); 445Assert.Same(connection.ServerRpc, await replacement); 456registry.AddIntegrationHost("original", original.ServerRpc, original.CallbackInvoker); 457Assert.Same(original.ServerRpc, await registration); 464Assert.Equal(ownsCallbacks, registry.MarkHostUnavailable(original.ServerRpc)); 465Assert.Equal(ownsCallbacks, registry.MarkHostUnavailable(original.ServerRpc)); 468registry.AddIntegrationHost(replacement.ServerRpc); 472original.ServerRpc, replacement.ServerRpc, TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken)); 486original.ServerRpc, replacement.ServerRpc, TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken); 501registry.AddIntegrationHost(original.ServerRpc); 502registry.AddIntegrationHost(other.ServerRpc); 504registry.MarkHostUnavailable(original.ServerRpc); 509registry.AddIntegrationHost(replacement.ServerRpc); 510await registry.ReplaceHostAsync(original.ServerRpc, replacement.ServerRpc, TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken); 531registry.AddIntegrationHost(original.ServerRpc); 533registry.MarkHostUnavailable(original.ServerRpc); 534registry.AddIntegrationHost(replacement.ServerRpc); 537original.ServerRpc, replacement.ServerRpc, TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken)); 557registry.AddIntegrationHost(original.ServerRpc); 559registry.MarkHostUnavailable(original.ServerRpc); 560registry.AddIntegrationHost(replacement.ServerRpc); 563original.ServerRpc, replacement.ServerRpc, TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken)); 582registry.AddIntegrationHost(original.ServerRpc); 584registry.MarkHostUnavailable(original.ServerRpc); 588original.ServerRpc, replacement.ServerRpc, TimeSpan.Zero, TestContext.Current.CancellationToken)); 607registry.AddIntegrationHost(first.ServerRpc); 608registry.AddIntegrationHost(second.ServerRpc); 610registry.MarkHostUnavailable(first.ServerRpc); 611registry.MarkHostUnavailable(second.ServerRpc); 612registry.AddIntegrationHost(firstReplacement.ServerRpc); 613registry.AddIntegrationHost(secondReplacement.ServerRpc); 616registry.ReplaceHostAsync(first.ServerRpc, firstReplacement.ServerRpc, TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken), 617registry.ReplaceHostAsync(second.ServerRpc, secondReplacement.ServerRpc, TimeSpan.FromSeconds(10), TestContext.Current.CancellationToken)); 634registry.AddIntegrationHost(connection.ServerRpc); 669registry.AddIntegrationHost(connection.ServerRpc); 720registry.AddIntegrationHost(connection.ServerRpc); 747registry.AddIntegrationHost(connection.ServerRpc); 773registry.AddIntegrationHost(connection.ServerRpc); 803registry.AddIntegrationHost(connection.ServerRpc); 821registry.AddIntegrationHost(connection.ServerRpc); 822registry.AddIntegrationHost(successfulConnection.ServerRpc); 844registry.AddIntegrationHost(firstConnection.ServerRpc); 847registry.AddIntegrationHost(secondConnection.ServerRpc); 870registry.AddIntegrationHost(firstConnection.ServerRpc); 872registry.AddIntegrationHost(secondConnection.ServerRpc); 887registry.AddIntegrationHost(connection.ServerRpc); 912registry.AddIntegrationHost(firstConnection.ServerRpc); 913registry.AddIntegrationHost(secondConnection.ServerRpc); 949registry.AddIntegrationHost(connection.ServerRpc);

116registry.AddIntegrationHost(firstConnection.ServerRpc); 123registry.AddIntegrationHost(secondConnection.ServerRpc); 141registry.AddIntegrationHost(connection.ServerRpc); 161registry.AddIntegrationHost(connection.ServerRpc); 162registry.MarkHostUnavailable(connection.ServerRpc);

35invoker.SetConnection(connection.ServerRpc); 46await connection.ServerRpc.Completion.WaitAsync(TestContext.Current.CancellationToken); 74invoker.SetConnection(connection.ServerRpc);

44CallbackInvoker.SetConnection(ServerRpc); 63ServerRpc.StartListening(); 77ServerRpc.Dispose();