LINQ to Events(Rx/CEP)