Perché dovrei usare la chiusura mittente con PipeTo()?

Question

Ecco the official sample di utilizzare PipeTo() in Akka.NET:

Receive<BeginProcessFeed>(feed => 
{ 
    //instance variable for closure 
    var senderClosure = Sender; 
    SendMessage(string.Format("Downloading {0} for RSS/ATOM processing...", feed.FeedUri)); 

    //reply back to the sender 
    _feedFactory.CreateFeedAsync(feed.FeedUri).PipeTo(senderClosure); 
}); 

La domanda è: perché dovremmo usare Sender chiusura qui? Perché non usare solo:

In questo esempio e nei documenti si dice che è obbligatorio utilizzare la chiusura qui. Ma non vedo alcun motivo per farlo.

Se si utilizza ContinueWith() è ragionevole utilizzare la chiusura all'interno della continuazione, ma non come parametro PipeTo().

Mi manca qualcosa?

Answer 1

due cose da capire qui:

1. Sender non è una proprietà statica. Sender is actually a function on the IActorContext che restituisce il mittente del messaggio corrente in fase di elaborazione. Il valore restituito cambia ogni volta che il contesto riceve un nuovo messaggio dalla casella di posta.

2. PipeTo è una continuazione, e quando la continuazione eseguito sul ThreadPool, chiamando Sender avrà accesso alla stessa identica IActorContext oggetto che ha iniziato l'attività. Non vi è alcuna garanzia che l'attuale Sender nel contesto sia lo stesso, poiché i nuovi messaggi vengono inseriti nell'attore per l'elaborazione dall'avvio dell'attività.

Così abbiamo cache il valore della Sender in una variabile locale per garantire che noi stiamo puntando PipeTo alla giusta IActorRef ogni volta che viene eseguito.