E>>IObservable<StockAlert> alerts = ticks.Parse(parser => 
E>>        from next in parser  //Служебный кусок
E>>        let ups = next.Where(tick => tick.Change > 0)  //Разделение потока событий на положительные  
E>>        let downs = next.Where(tick => tick.Change < 0)//и отрицательные
E>>        select (from up in ups.AtLeast(2) //Если сначала иду как минимум два положительных
E>>                from down in downs        //Затем отрицательный
E>>                where down.Change <= -11  //Когда у отрицательного изменения <= -11
E>>                select new StockAlert(up.ToEnumerable(), down)) //Возвращаем StockAlert
E>>               .Or //Или
E>>               (from down in downs.AtLeast(2) //Сначала как минимум два отрицательных
E>>                from up in ups                //Потом положительный
E>>                where up.Change >= 21         //Со значением более 21
E>>                select new StockAlert(down.ToEnumerable(), up))); //Возвращаем StockAlert
E>>

E>>>IObservable<StockAlert> alerts = ticks.Parse(parser => 
E>>>        from next in parser  //Служебный кусок
E>>>        let ups = next.Where(tick => tick.Change > 0)  //Разделение потока событий на положительные  
E>>>        let downs = next.Where(tick => tick.Change < 0)//и отрицательные
E>>>        select (from up in ups.AtLeast(2) //Если сначала иду как минимум два положительных
E>>>                from down in downs        //Затем отрицательный
E>>>                where down.Change <= -11  //Когда у отрицательного изменения <= -11
E>>>                select new StockAlert(up.ToEnumerable(), down)) //Возвращаем StockAlert
E>>>               .Or //Или
E>>>               (from down in downs.AtLeast(2) //Сначала как минимум два отрицательных
E>>>                from up in ups                //Потом положительный
E>>>                where up.Change >= 21         //Со значением более 21
E>>>                select new StockAlert(down.ToEnumerable(), up))); //Возвращаем StockAlert
E>>>

E>function filter(q : TTickQueue) : TTick;

E>    function isUp(t : TTick);
E>    begin
E>      Result := t.Change > 0
E>    end;
    
E>    function isDown(t : TTick);
E>    begin
E>      Result := t.Change < 0
E>    end;

E>begin
E>    if q.atLeast(2, isUp) and q(2).Change <= -11 then 
E>        begin            
E>            Result := StockAlert.Create(q[0].ToEnumerable(), down);
E>            q.pop(3);
E>        end
E>    else if q.atLeast(2, isDown) and isUp(q[2]) and q[2].Change > 21 then
E>        begin            
E>            Result := StockAlert.Create(q[0].ToEnumerable(), up);
E>            q.pop(3);
E>        end
E>    else
E>        q.pop();
E>end;

E>