Implemented interface member:
method
ConnectAsync
Aspire.Cli.Backchannel.IExtensionBackchannel.ConnectAsync(System.Threading.CancellationToken)
36 references to ConnectAsync
aspire (26)
Backchannel\ExtensionBackchannel.cs (26)
342await ConnectAsync(cancellationToken); 358await ConnectAsync(cancellationToken); 374await ConnectAsync(cancellationToken); 390await ConnectAsync(cancellationToken); 406await ConnectAsync(cancellationToken); 422await ConnectAsync(cancellationToken); 439await ConnectAsync(cancellationToken); 455await ConnectAsync(cancellationToken); 471await ConnectAsync(cancellationToken); 487await ConnectAsync(cancellationToken); 504await ConnectAsync(cancellationToken); 534await ConnectAsync(cancellationToken); 563await ConnectAsync(cancellationToken); 587await ConnectAsync(cancellationToken); 613await ConnectAsync(cancellationToken); 639await ConnectAsync(cancellationToken); 657await ConnectAsync(cancellationToken); 678await ConnectAsync(cancellationToken); 692await ConnectAsync(cancellationToken); 708await ConnectAsync(cancellationToken); 724await ConnectAsync(cancellationToken); 744await ConnectAsync(cancellationToken); 762await ConnectAsync(cancellationToken); 778await ConnectAsync(cancellationToken); 795await ConnectAsync(cancellationToken); 812await ConnectAsync(CancellationToken.None);
Aspire.Cli.Tests (10)
Backchannel\ExtensionBackchannelTests.cs (10)
21await Assert.ThrowsAsync<ArgumentException>(() => backchannel.ConnectAsync(CancellationToken.None)).DefaultTimeout(); 22await Assert.ThrowsAsync<ArgumentException>(() => backchannel.ConnectAsync(CancellationToken.None)).DefaultTimeout(); 42var firstConnectTask = backchannel.ConnectAsync(CancellationToken.None); 46.Select(_ => backchannel.ConnectAsync(CancellationToken.None)) 57var retryException = await Assert.ThrowsAsync<InvalidOperationException>(() => backchannel.ConnectAsync(CancellationToken.None)).DefaultTimeout(); 80var firstConnectTask = backchannel.ConnectAsync(CancellationToken.None); 84.Select(_ => backchannel.ConnectAsync(CancellationToken.None)) 95var retryException = await Assert.ThrowsAsync<ExtensionIncompatibleException>(() => backchannel.ConnectAsync(CancellationToken.None)).DefaultTimeout(); 128var firstConnectTask = backchannel.ConnectAsync(firstConnectorCts.Token); 132.Select(_ => backchannel.ConnectAsync(CancellationToken.None))