Реактивный пример FParsec

Question

Я надеюсь, что кто-то потенциально может опубликовать пример использования FParsec, где данные основаны на каком-то входящем живом потоке.

В некоторых примерах может быть получен результат, основанный на жестах мыши, генерирование предупреждения или уведомления на основе определенной последовательности биржевых отметок.

Если бы кто-то мог опубликовать пример, он был бы очень признателен.

Спасибо!

Answer 1

То, что вы ищете, это Reactive Parsers из Rxx.

Это не F#, а скорее библиотека.NET, которая позволяет вам писать такой код (следуя из вашего исходного примера):

    var alerts = ticks.Parse(parser =>
    from next in parser
    let ups = next.Where(tick => tick.Change > 0)
    let downs = next.Where(tick => tick.Change < 0)
    let downAlert = from manyUps in ups.AtLeast(2).ToList()
               from reversalDown in downs.NonGreedy()
               where reversalDown.Change <= -11
               select new StockAlert(manyUps, reversalDown)
    let upAlert = from manyDowns in downs.AtLeast(2).ToList()
            from reversalUp in ups.NonGreedy()
            where reversalUp.Change >= 21
            select new StockAlert(manyDowns, reversalUp)
    select downAlert.Or(upAlert).Ambiguous(untilCount: 1));

Конечно же, это заслуга Дейва Секстона и Джеймса Майлза, которые сделали большую часть этой работы.

Для фонового чтения из этого обсуждения вышли расширения синтаксического анализатора Rxx: http://qa.social.msdn.microsoft.com/Forums/eu/rx/thread/0f72e5c0-1476-4969-92da-633000346d0d

Вот очень простой пример того, как это можно использовать в F#:

open Rxx.Parsers.Reactive
open Rxx.Parsers.Reactive.Linq

// F# shortcuts to Rxx
let where f (a:IObservableParser<_,_>) = a.Where(fun b -> f b)
let toList (parser:IObservableParser<_,_>) = parser.ToList()
let (<&>) (a:IObservableParser<'a,'b>) (b:IObservableParser<'a,'b>) = a.And(b)
let create a = 
    { new ObservableParser<_,_>() with
        override x.Start = a(x.Next) } :> IObservableParser<_,_>
let parse (parser:IObservableParser<_,_>) (obs:IObservable<_>) = obs.Parse(parser)

// example of grammar
let grammar = 
    (fun (parser:IObservableParser<_,_>) ->
        let next = parser.Next
        let bigs = next |> where(fun i -> i > 25)
        let smalls = next |> where(fun i -> i <= 25)
        bigs <&> smalls |> toList ) 
    |> create

// the test
let random = Random()
let values = Observable.Interval(TimeSpan.FromMilliseconds(500.0)).Select( fun _ -> random.Next(1,50)).Trace().TraceSubscriptions("subbing","subbed","disposing","disposed").Publish()

let sub = values |> parse grammar |> Observable.add(printfn "BIG THEN SMALL: %A")
let test = values.Connect()