Zero/ZeroLevel/Services/Network/Services/ZExSocketObservableServer.cs

using System;
using System.Net;

namespace ZeroLevel.Network
{
    public class ZExSocketObservableServer :
        ZSocketServer, IZObservableServer
    {
        public ZExSocketObservableServer(IPEndPoint endpoint)
            : base(endpoint)
        {
        }

        public IPEndPoint Endpoint => base.LocalEndpoint;

        public event Action<Frame, IZBackward> OnMessage = (_, __) => { };

        public event Func<Frame, IZBackward, Frame> OnRequest = (_, __) => null;

        protected override void Handle(Frame frame, IZBackward client)
        {
            OnMessage(frame, client);
        }

        protected override Frame HandleRequest(Frame frame, IZBackward client)
        {
            return OnRequest(frame, client);
        }
    }
}