PlazaStreamManager

StockSharp.Plaza

Менеджер потоков данных.

实现: IPlazaStreamManager

构造函数

PlazaStreamManager(string, PlazaTableRegistry, PlazaRevisionManager, SynchronizedDictionary<PlazaStream, int>, PlazaConnectionPool, Action<Message>)

Менеджер потоков данных.

属性

ConnectionGroupping : SynchronizedDictionary<PlazaStream, int>

Настройки группировки потоков по соединениям.

事件

Begin : Action<PlazaStream, PlazaTable[]>

Событие начала обработки данных.

Cleared : Action<PlazaStream, PlazaTable, long>

Событие удаления данных.

End : Action<PlazaStream, PlazaTable[]>

Событие окончания обработки данных.

Flushed : Action<PlazaStream, PlazaTable[]>

Событие сброса состояния всего потока.

Inserted : Action<PlazaStream, PlazaTable, IPlazaRecord>

Событие вставки новых данных.

Online : Action<PlazaStream, PlazaTable[]>

Событие перехода в онлайн.