1 implementation of IMessageSource
Microsoft.ML.Core (1)
Environment\HostEnvironmentBase.cs (1)
156protected abstract class PipeBase<TMessage> : ChannelProviderBase, IPipe<TMessage>, IMessageSource
22 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)
Microsoft.ML.Data (4)
MLContext.cs (1)
162private void ProcessMessage(IMessageSource source, ChannelMessage message)
Utilities\LocalEnvironment.cs (3)
21Action<IMessageSource, ChannelMessage> dispatch) 57public void AddListener(Action<IMessageSource, ChannelMessage> listener) 63public void RemoveListener(Action<IMessageSource, ChannelMessage> listener)