Akkling perisistence example

Program.fs

open System
open System.Threading
open Akkling
open Akkling.Persistence

let system = System.create "persistent-system" (Configuration.defaultConfig())

type Event =
    | Added of int
    | Removed of int

type Command =
    | Add of int
    | Remove of int
    | GetState

let apply state = function
    | Added i -> i::state
    | Removed i -> 
        let rec remove i list =
            match list with
            | [] -> []
            | x::xs when x = i -> xs
            | x::xs -> x::(remove i xs)
        remove i state

let testSpawn () = 
    spawnPersist system "pid-1" []
    <| fun mailbox ->
        {
            apply = apply
            exec =
                let rec loop () = 
                    actor {
                        let! msg = mailbox.Receive()
                        match msg with
                        | Add i -> mailbox.PersistEvent (apply (mailbox.State())) [Added i]
                        | Remove i -> mailbox.PersistEvent (apply (mailbox.State())) [Removed i]
                        | GetState -> mailbox.Sender() <! mailbox.State()
                        return! loop ()
                    }
                loop ()
        }
    <| []

let pref = testSpawn ()

pref <! Add 1
pref <! Add 2
pref <! Add 3
pref <! Remove 2

Thread.Sleep 1000

async {
    let! (data : int list) = pref <? GetState
    printfn "Current state: %A" data
} |> Async.RunSynchronously

Console.ReadLine()