export interface IDataPublisher {
    next<T>(state: T): any;
}