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)

19private readonly Message _request; 25Message request, 114Message request, 175var progress = MessageUtilities.Create(

Plugins\Connection.cs (1)

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

Plugins\IConnection.cs (1)

57Task SendAsync(Message message, CancellationToken cancellationToken);

Plugins\IMessageDispatcher.cs (6)

33Message CreateMessage(MessageType type, MessageMethod method); 43Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload) 52Task DispatchCancelAsync(Message request, CancellationToken cancellationToken); 61Task DispatchFaultAsync(Message request, Fault fault, CancellationToken cancellationToken); 70Task DispatchProgressAsync(Message request, Progress progress, CancellationToken cancellationToken); 98Task DispatchResponseAsync<TOutbound>(Message request, TOutbound responsePayload, CancellationToken cancellationToken)

Plugins\InboundRequestContext.cs (5)

101private async Task ProcessResponseAsync(IRequestHandler requestHandler, Message request, IResponseHandler responseHandler) 118var response = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 171public void BeginFaultAsync(Message request, Exception exception) 183var response = new Message( 233Message request,

Plugins\IRequestHandler.cs (1)

37Message request,

Plugins\IResponseHandler.cs (1)

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

Plugins\ISender.cs (1)

40Task 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)

143public Message CreateMessage(MessageType type, MessageMethod method) 159public Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload) 181public Task DispatchCancelAsync(Message request, CancellationToken cancellationToken) 211public Task DispatchFaultAsync(Message request, Fault fault, CancellationToken cancellationToken) 242public Task DispatchProgressAsync(Message request, Progress progress, CancellationToken cancellationToken) 318Message request, 371Message request, 381Message request, 391var message = MessageUtilities.Create(request.RequestId, type, request.Method, payload); 405Message request, 408var message = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 415Message request, 419Message message; 439Message request, 443var message = MessageUtilities.Create(request.RequestId, MessageType.Progress, request.Method, progress); 450Message response, 467var message = CreateMessage(type, method, payload); 588private void HandleInboundCancel(Message message) 600private void HandleInboundFault(Message fault) 612private void HandleInboundRequest(Message message) 681Message message, 693Message message,

Plugins\MessageEventArgs.cs (2)

16public Message Message { get; } 23public MessageEventArgs(Message message)

Plugins\Messages\Message.cs (1)

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

Plugins\MessageUtilities.cs (9)

19/// Instantiates a new <see cref="Message" /> class. 24/// <returns>a <see cref="Message" /> instance.</returns> 27public static Message Create( 41/// Instantiates a new <see cref="Message" /> class. 48/// <returns>a <see cref="Message" /> instance.</returns> 52public static Message Create<TPayload>( 74/// Use this instead of accessing the obsolete <see cref="Message.Payload" /> directly. 83public static string? SerializePayload(Message message) 120public static TPayload? DeserializePayload<TPayload>(Message message)

Plugins\OutboundRequestContext.cs (3)

45public abstract void HandleProgress(Message progress); 52public abstract void HandleResponse(Message response); 59public abstract void HandleFault(Message fault);

Plugins\OutboundRequestContext`1.cs (6)

28private readonly Message _request; 55Message request, 83Message request, 157public override void HandleProgress(Message progress) 182public override void HandleResponse(Message response) 203public override void HandleFault(Message fault)

Plugins\PluginFactory.cs (1)

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

Plugins\PluginJsonContext.cs (1)

11[JsonSerializable(typeof(Message))]

Plugins\ProtocolErrorEventArgs.cs (2)

21public Message? Message { get; } 45public ProtocolErrorEventArgs(Exception exception, Message message)

Plugins\Receiver.cs (2)

61protected void FireFaultEvent(Exception exception, Message? message) 70protected void FireMessageReceivedEvent(Message message)

Plugins\RequestHandlers\CloseRequestHandler.cs (1)

62Message request,

Plugins\RequestHandlers\GetCredentialsRequestHandler.cs (1)

119Message request,

Plugins\RequestHandlers\GetServiceIndexRequestHandler.cs (1)

103Message request,

Plugins\RequestHandlers\LogRequestHandler.cs (1)

61Message request,

Plugins\RequestHandlers\MonitorNuGetProcessExitRequestHandler.cs (1)

79Message request,

Plugins\RequestHandlers\SymmetricHandshake.cs (1)

164Message request,

Plugins\Sender.cs (1)

120public Task SendAsync(Message message, CancellationToken cancellationToken)

Plugins\StandardInputReceiver.cs (2)

112Message? message = null; 139message = JsonSerializationUtilities.Deserialize<Message>(line);

Plugins\StandardOutputReceiver.cs (2)

103Message? message = null; 122message = JsonSerializationUtilities.Deserialize<Message>(line);