12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394 |
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text;
- using System.Threading.Tasks;
- using Edge.Core.Parser.BinaryParser.MessageEntity;
- using Edge.Core.Parser;
- using Edge.Core.Processor;
- using Edge.Core.IndustryStandardInterface.Pump;
- using Edge.Core.Processor.Communicator;
- namespace Edge.Core.Processor
- {
- public interface IContext<TRaw, TMessage> : IDisposable where TMessage : MessageBase
- {
-
- IDeviceProcessor<TRaw, TMessage> Processor { get; }
- IDeviceHandler<TRaw, TMessage> Handler { get; }
- ICommunicator<TRaw, TMessage> Communicator { get; }
- IIncoming<TMessage> Incoming { get; }
- IOutgoing<TRaw, TMessage> Outgoing { get; }
- }
-
-
-
-
-
-
-
- public class Context<TRaw, TMessage> : IContext<TRaw, TMessage> where TMessage : MessageBase
- {
-
-
- public IDeviceProcessor<TRaw, TMessage> Processor { get; }
- public IDeviceHandler<TRaw, TMessage> Handler { get; }
- public ICommunicator<TRaw, TMessage> Communicator { get; }
- public IIncoming<TMessage> Incoming { get; }
- public IOutgoing<TRaw, TMessage> Outgoing { get; }
- public Context(IDeviceProcessor<TRaw, TMessage> processor, IDeviceHandler<TRaw, TMessage> handler, ICommunicator<TRaw, TMessage> communicator, IIncoming<TMessage> incoming, IOutgoing<TRaw, TMessage> outgoing)
- {
- this.Processor = processor;
- this.Communicator = communicator;
- this.Incoming = incoming;
- this.Outgoing = outgoing;
- this.Handler = handler;
- }
- public void Dispose()
- {
- if (this.Incoming is IDisposable idp)
- idp.Dispose();
- if (this.Outgoing is IDisposable odp)
- odp.Dispose();
- }
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- }
|