1 implementation of IMessageSource
Microsoft.ML.Core (1)
Environment\HostEnvironmentBase.cs (1)
156protected abstract class PipeBase<TMessage> : ChannelProviderBase, IPipe<TMessage>, IMessageSource
18 references to IMessageSource
Microsoft.ML.Core (18)
Environment\ConsoleEnvironment.cs (3)
54public void PrintMessage(IMessageSource sender, ChannelMessage msg) 332Action<IMessageSource, ChannelMessage> dispatch) 389private void PrintMessage(IMessageSource src, ChannelMessage msg)
Environment\HostEnvironmentBase.cs (15)
161protected readonly Action<IMessageSource, TMessage> Dispatch; 168Action<IMessageSource, TMessage> dispatch) 218Action<IMessageSource, ChannelMessage> dispatch) 271Action<IMessageSource, TMessage> dispatch) : 297private volatile Action<IMessageSource, TMessage> _listenerAction; 302private readonly Action<IMessageSource, TMessage> _dispatch; 309public Action<IMessageSource, TMessage> Dispatch { get { return _dispatch; } } 311private void DispatchCore(IMessageSource sender, TMessage message) 316public void AddListener(Action<IMessageSource, TMessage> listenerFunc) 322public void RemoveListener(Action<IMessageSource, TMessage> listenerFunc) 452Action<IMessageSource, TMessage> listenerAction, IMessageSource channel, TMessage message) 459protected Action<IMessageSource, TMessage> GetDispatchDelegate<TMessage>() 497public void AddListener<TMessage>(Action<IMessageSource, TMessage> listenerFunc) 504public void RemoveListener<TMessage>(Action<IMessageSource, TMessage> listenerFunc)