Message

_generated\72\PluginJsonContext.Message.g.cs (9)

_generated\95\PluginJsonContext.GetJsonTypeInfo.g.cs (1)

138if (type == typeof(global::NuGet.Protocol.Plugins.Message))

Plugins\AutomaticProgressReporter.cs (4)

21private readonly Message _request; 27Message request, 116Message request, 177var progress = MessageUtilities.Create(

Plugins\Connection.cs (1)

227public async Task SendAsync(Message message, CancellationToken cancellationToken)

Plugins\IConnection.cs (1)

59Task SendAsync(Message message, CancellationToken cancellationToken);

Plugins\IMessageDispatcher.cs (6)

35Message CreateMessage(MessageType type, MessageMethod method); 45Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload) 54Task DispatchCancelAsync(Message request, CancellationToken cancellationToken); 63Task DispatchFaultAsync(Message request, Fault fault, CancellationToken cancellationToken); 72Task DispatchProgressAsync(Message request, Progress progress, CancellationToken cancellationToken); 100Task DispatchResponseAsync<TOutbound>(Message request, TOutbound responsePayload, CancellationToken cancellationToken)

Plugins\InboundRequestContext.cs (5)

103private async Task ProcessResponseAsync(IRequestHandler requestHandler, Message request, IResponseHandler responseHandler) 120var response = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 173public void BeginFaultAsync(Message request, Exception exception) 185var response = new Message( 235Message request,

Plugins\IRequestHandler.cs (1)

39Message request,

Plugins\IResponseHandler.cs (1)

29Task SendResponseAsync<TPayload>(Message request, TPayload payload, CancellationToken cancellationToken)

Plugins\ISender.cs (1)

42Task SendAsync(Message message, CancellationToken cancellationToken);

Plugins\MessageConverter.cs (13)

12internal sealed class MessageConverter : JsonConverter<Message> 103public override Message Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options) 108if (!root.TryGetProperty(nameof(Message.RequestId), out var requestIdProp)) 110throw new JsonException(string.Format(CultureInfo.CurrentCulture, Strings.Error_RequiredJsonPropertyMissing, nameof(Message.RequestId))); 116throw new JsonException(string.Format(CultureInfo.CurrentCulture, Strings.ArgumentCannotBeNullOrEmpty, nameof(Message.RequestId))); 119if (!root.TryGetProperty(nameof(Message.Type), out var typeProp)) 121throw new JsonException(string.Format(CultureInfo.CurrentCulture, Strings.Error_RequiredJsonPropertyMissing, nameof(Message.Type))); 130if (!root.TryGetProperty(nameof(Message.Method), out var methodProp)) 132throw new JsonException(string.Format(CultureInfo.CurrentCulture, Strings.Error_RequiredJsonPropertyMissing, nameof(Message.Method))); 170public override void Write(Utf8JsonWriter writer, Message value, JsonSerializerOptions options) 173writer.WriteString(nameof(Message.RequestId), value.RequestId); 174writer.WriteString(nameof(Message.Type), value.Type.ToString()); 175writer.WriteString(nameof(Message.Method), value.Method.ToString());

Plugins\MessageDispatcher.cs (22)

142public Message CreateMessage(MessageType type, MessageMethod method) 158public Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload) 180public Task DispatchCancelAsync(Message request, CancellationToken cancellationToken) 210public Task DispatchFaultAsync(Message request, Fault fault, CancellationToken cancellationToken) 241public Task DispatchProgressAsync(Message request, Progress progress, CancellationToken cancellationToken) 317Message request, 370Message request, 380Message request, 392var message = MessageUtilities.Create(request.RequestId, type, request.Method, payload); 406Message request, 409var message = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 416Message request, 420Message message; 440Message request, 444var message = MessageUtilities.Create(request.RequestId, MessageType.Progress, request.Method, progress); 451Message response, 468var message = CreateMessage(type, method, payload); 591private void HandleInboundCancel(Message message) 601private void HandleInboundFault(Message fault) 613private void HandleInboundRequest(Message message) 690Message message, 702Message message,

Plugins\MessageEventArgs.cs (2)

18public Message Message { get; } 25public MessageEventArgs(Message message)

Plugins\Messages\Message.cs (1)

49/// Initializes a new instance of the <see cref="Message" /> class.

Plugins\MessageUtilities.cs (9)

17/// Instantiates a new <see cref="Message" /> class. 22/// <returns>a <see cref="Message" /> instance.</returns> 25public static Message Create( 39/// Instantiates a new <see cref="Message" /> class. 46/// <returns>a <see cref="Message" /> instance.</returns> 50public static Message Create<TPayload>( 72/// Use this instead of accessing the obsolete <see cref="Message.Payload" /> directly. 77public static string SerializePayload(Message message) 110public static TPayload DeserializePayload<TPayload>(Message message)

Plugins\OutboundRequestContext.cs (3)

47public abstract void HandleProgress(Message progress); 54public abstract void HandleResponse(Message response); 61public abstract void HandleFault(Message fault);

Plugins\OutboundRequestContext`1.cs (6)

27private readonly Message _request; 54Message request, 82Message request, 152public override void HandleProgress(Message progress) 172public override void HandleResponse(Message response) 189public override void HandleFault(Message fault)

Plugins\PluginFactory.cs (1)

445var message = plugin.Connection.MessageDispatcher.CreateMessage(

Plugins\PluginJsonContext.cs (1)

11[JsonSerializable(typeof(Message))]

Plugins\ProtocolErrorEventArgs.cs (2)

23public Message Message { get; } 47public ProtocolErrorEventArgs(Exception exception, Message message)

Plugins\Receiver.cs (2)

63protected void FireFaultEvent(Exception exception, Message message) 72protected void FireMessageReceivedEvent(Message message)

Plugins\RequestHandlers\CloseRequestHandler.cs (1)

64Message request,

Plugins\RequestHandlers\GetCredentialsRequestHandler.cs (1)

114Message request,

Plugins\RequestHandlers\GetServiceIndexRequestHandler.cs (1)

98Message request,

Plugins\RequestHandlers\LogRequestHandler.cs (1)

58Message request,

Plugins\RequestHandlers\MonitorNuGetProcessExitRequestHandler.cs (1)

74Message request,

Plugins\RequestHandlers\SymmetricHandshake.cs (1)

159Message request,

Plugins\Sender.cs (1)

122public Task SendAsync(Message message, CancellationToken cancellationToken)

Plugins\StandardInputReceiver.cs (2)

114Message message = null; 137message = JsonSerializationUtilities.Deserialize<Message>(line);

Plugins\StandardOutputReceiver.cs (2)

105Message message = null; 119message = JsonSerializationUtilities.Deserialize<Message>(e.Line);