14 references to CallbackInvoker
Aspire.Hosting.RemoteHost.Tests (14)
ExternalCapabilityRegistryTests.cs (12)
198await registry.TryInvokeAsync("test.external/callback", new JsonObject { ["configure"] = "guest_callback" }, guest.CallbackInvoker); 206registry.RemoveGuestCallbacks(guest.CallbackInvoker); 211"test.external/callback", new JsonObject { ["configure"] = "late_callback" }, guest.CallbackInvoker)); 370registry.AddIntegrationHost("integration", integration.ServerRpc, integration.CallbackInvoker); 424Assert.Throws<InvalidOperationException>(() => registry.AddIntegrationHost("unknown", connection.ServerRpc, connection.CallbackInvoker)); 426registry.AddIntegrationHost("attempt", connection.ServerRpc, connection.CallbackInvoker); 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); 456registry.AddIntegrationHost("original", original.ServerRpc, original.CallbackInvoker); 461original.CallbackInvoker.RegisterCallback(); 466Assert.Throws<ObjectDisposedException>(original.CallbackInvoker.RegisterCallback);
TestServices\IntegrationHostTestConnection.cs (2)
44CallbackInvoker.SetConnection(ServerRpc); 79CallbackInvoker.Dispose();