Могу ли я иметь асинхронный агент, который слушает и отвечает на 2 события?

Question

Я хотел бы иметь агента, который действует как SMTP-сервер, который асинхронно ждет сообщений электронной почты, а также запросы служб для получения списка полученных электронных писем. Агент будет выглядеть примерно так:

let agent = Agent.Start(fun inbox ->  
    let rec loop emails = async { 
    let! email = ReceiveEmail() 
    let emails = email::emails 
    let! emailStatusRequest = inbox.Receive() 
    match emailStatusRequest with 
    | Get channel -> channel.Reply emails 
    return! loop emails } 
    loop []) 

Это будет ждать сообщения электронной почты, а затем ждать запроса статуса. Как мне отделить заказ, чтобы агент реагировал на то, какое событие происходит первым - событие, полученное по электронной почте, или запрос на получение сообщения электронной почты? Является ли агент идеальным инструментом для моделирования этого?

Answer 1

Я бы переместил часть ReceiveEmail в свою собственную асинхронную петлю и опубликовал ее сообщения вашему агенту.

что-то вроде этого (предупреждение: не тестировалось - лечить, как псевдо-код):

type AgentCommands = 
    | Received of Email 
    | StatusRequest of RequestParams 
    | ... 

let agent = Agent.Start(fun inbox ->  
    let rec loop emails = async { 
    let! cmd = inbox.Receive 
    match cmd with 
    | Received email -> 
     let emails = email::emails 
     return! loop emails 
    | StatusRequest emailStatusRequest -> 
     match emailStatusRequest with 
     | Get channel -> channel.Reply emails 
    return! loop emails } 
    loop []) 

let receiveLoop = async { 
     while true do 
     let! email = ReceiveEmail() 
     agent.Post (Received email) 
    } |> Async.Start 

, конечно, вы, вероятно, необходимо при поддержке CancellationToken ... вы получите его;)