45 references to MessageType
NuGet.Protocol (45)
Plugins\AutomaticProgressReporter.cs (1)
179MessageType.Progress,
Plugins\IMessageDispatcher.cs (2)
35Message CreateMessage(MessageType type, MessageMethod method); 45Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload)
Plugins\InboundRequestContext.cs (2)
120var response = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 187MessageType.Fault,
Plugins\Logging\CommunicationLogMessage.cs (2)
14private readonly MessageType _type; 16internal CommunicationLogMessage(DateTimeOffset now, string requestId, MessageMethod method, MessageType type, MessageState state)
Plugins\Logging\TaskLogMessage.cs (2)
16private readonly MessageType _type; 18internal TaskLogMessage(DateTimeOffset now, string requestId, MessageMethod method, MessageType type, TaskState state)
Plugins\MessageDispatcher.cs (24)
142public Message CreateMessage(MessageType type, MessageMethod method) 158public Message CreateMessage<TPayload>(MessageType type, MessageMethod method, TPayload payload) 298MessageType.Request, 342return DispatchAsync(connection, MessageType.Response, request, responsePayload, cancellationToken); 379MessageType type, 409var message = MessageUtilities.Create(request.RequestId, MessageType.Cancel, request.Method); 426message = new Message(requestId, MessageType.Fault, MessageMethod.None, fault); 432message = new Message(request.RequestId, MessageType.Fault, request.Method, fault); 444var message = MessageUtilities.Create(request.RequestId, MessageType.Progress, request.Method, progress); 461MessageType type, 481case MessageType.Request: 482case MessageType.Response: 483case MessageType.Fault: 541case MessageType.Response: 545case MessageType.Progress: 549case MessageType.Fault: 553case MessageType.Cancel: 570case MessageType.Cancel: 574case MessageType.Request: 578case MessageType.Fault: 716private static bool GetIsKeepAlive(MessageType type, MessageMethod method) 718if (type == MessageType.Request && method == MessageMethod.Handshake) 726private static TimeSpan GetRequestTimeout(IConnection connection, MessageType type, MessageMethod method) 728if (type == MessageType.Request && method == MessageMethod.Handshake)
Plugins\Messages\Message.cs (5)
28public MessageType Type { get; } 57/// is an undefined <see cref="MessageType" /> value.</exception> 61public Message(string requestId, MessageType type, MessageMethod method, JObject payload = null) 66internal Message(string requestId, MessageType type, MessageMethod method, object payload = null) 73if (!Enum.IsDefined(typeof(MessageType), type))
Plugins\MessageUtilities.cs (2)
27MessageType type, 52MessageType type,
Plugins\OutboundRequestContext`1.cs (4)
141MessageType.Cancel)); 259_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Queued)); 269_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Executing)); 281_logger.Write(new TaskLogMessage(_logger.Now, _request.RequestId, _request.Method, MessageType.Cancel, TaskState.Completed));
Plugins\PluginFactory.cs (1)
446MessageType.Request,