2 implementations of Connection
NuGet.Protocol (2)
Plugins\NoOpDisposePlugin.cs (1)
50public IConnection Connection => _plugin.Connection;
Plugins\Plugin.cs (1)
53public IConnection Connection { get; }
30 references to Connection
NuGet.Credentials (4)
SecurePluginCredentialProvider.cs (4)
129var credentialResponse = await creationResult.Plugin.Connection.SendRequestAndReceiveResponseAsync<GetAuthenticationCredentialsRequest, GetAuthenticationCredentialsResponse>( 158() => plugin.Plugin.Connection.SendRequestAndReceiveResponseAsync<SetLogLevelRequest, SetLogLevelResponse>( 167plugin.Connection.MessageDispatcher.RequestHandlers.AddOrUpdate( 194plugin.Plugin.Connection.SendRequestAndReceiveResponseAsync<SetCredentialsRequest, SetCredentialsResponse>(
NuGet.Protocol (26)
Plugins\NoOpDisposePlugin.cs (1)
50public IConnection Connection => _plugin.Connection;
Plugins\PluginFactory.cs (2)
445var message = plugin.Connection.MessageDispatcher.CreateMessage( 453plugin.Connection.SendAsync(message, cancellationTokenSource.Token).Wait();
Plugins\PluginManager.cs (5)
289() => plugin.Connection.SendRequestAndReceiveResponseAsync<MonitorNuGetProcessExitRequest, MonitorNuGetProcessExitResponse>( 334if (plugin.Connection.ProtocolVersion.Equals(Plugins.ProtocolConstants.Version100) && (string.IsNullOrEmpty(packageSourceRepository) || serviceIndex == null)) 341var response = await plugin.Connection.SendRequestAndReceiveResponseAsync<GetOperationClaimsRequest, GetOperationClaimsResponse>( 419var response = await plugin.Connection.SendRequestAndReceiveResponseAsync<InitializeRequest, InitializeResponse>( 429plugin.Connection.Options.SetRequestTimeout(requestTimeout);
Plugins\PluginPackageDownloader.cs (1)
202var response = await _plugin.Connection.SendRequestAndReceiveResponseAsync<GetPackageHashRequest, GetPackageHashResponse>(
Plugins\PluginPackageReader.cs (4)
286var response = await _plugin.Connection.SendRequestAndReceiveResponseAsync<CopyFilesInPackageRequest, CopyFilesInPackageResponse>( 934var response = await _plugin.Connection.SendRequestAndReceiveResponseAsync<CopyNupkgFileRequest, CopyNupkgFileResponse>( 1033var response = await _plugin.Connection.SendRequestAndReceiveResponseAsync<CopyFilesInPackageRequest, CopyFilesInPackageResponse>( 1072var response = await _plugin.Connection.SendRequestAndReceiveResponseAsync<GetFilesInPackageRequest, GetFilesInPackageResponse>(
Plugins\RequestHandlers\GetCredentialsRequestHandler.cs (1)
149_plugin.Connection,
Providers\DownloadResourcePluginProvider.cs (2)
84plugin.Connection.MessageDispatcher.RequestHandlers.AddOrUpdate( 102plugin.Connection.MessageDispatcher.RequestHandlers.AddOrUpdate(
RemoteRepositories\PluginFindPackageByIdResource.cs (4)
283var response = await _plugin.Connection.SendRequestAndReceiveResponseAsync<PrefetchPackageRequest, PrefetchPackageResponse>( 416var response = await _plugin.Connection.SendRequestAndReceiveResponseAsync<GetPackageVersionsRequest, GetPackageVersionsResponse>( 490plugin.Connection.MessageDispatcher.RequestHandlers.AddOrUpdate( 505await _plugin.Connection.SendRequestAndReceiveResponseAsync<SetLogLevelRequest, SetLogLevelResponse>(
RemoteRepositories\PluginFindPackageByIdResourceProvider.cs (2)
84plugin.Connection.MessageDispatcher.RequestHandlers.AddOrUpdate( 102plugin.Connection.MessageDispatcher.RequestHandlers.AddOrUpdate(
Resources\DownloadResourcePlugin.cs (3)
117var response = await _plugin.Connection.SendRequestAndReceiveResponseAsync<PrefetchPackageRequest, PrefetchPackageResponse>( 156plugin.Connection.MessageDispatcher.RequestHandlers.AddOrUpdate( 171await _plugin.Connection.SendRequestAndReceiveResponseAsync<SetLogLevelRequest, SetLogLevelResponse>(
Resources\PluginResource.cs (1)
98await plugin.Connection.SendRequestAndReceiveResponseAsync<SetCredentialsRequest, SetCredentialsResponse>(