Warum sollte ich den Sender mit PipeTo() schließen?

Question

Hier the official sample von PipeTo() in Akka.NET mit:

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); 
}); 

Die Frage ist, warum sollten wir hier Sender Schließung benutzen? Warum nicht einfach zu verwenden:

_feedFactory.CreateFeedAsync(feed.FeedUri).PipeTo(Sender); 

In diesem Beispiel und in dem docs es gesagt ist es zwingend notwendig, Schließung hier zu verwenden. Aber ich sehe keine Gründe dafür.

Wenn wir ContinueWith() verwendet haben, ist es sinnvoll, den Abschluss in der Fortsetzung zu verwenden, aber nicht als PipeTo() Parameter.

Vermisse ich etwas?

Answer 1

Zwei Dinge hier zu verstehen:

1. Sender keine statische Eigenschaft ist. Sender is actually a function on the IActorContext, die den Absender der aktuellen Nachricht zurückgibt, die verarbeitet wird. Der zurückgegebene Wert ändert sich jedes Mal, wenn der Kontext eine neue Nachricht vom Postfach erhält.

2. PipeTo ist eine Fortsetzung, und wenn diese Fortsetzung auf dem Threadpool ausgeführt wird, wird Zugriff auf genau die gleiche IActorContext Objekt Sender Aufruf, der die Aufgabe gestartet. Es gibt keine Garantie, dass der aktuelle Sender im Kontext derselbe ist, weil neue Nachrichten in den Aktor zur Verarbeitung seit dem Start der Aufgabe geschoben werden.

So cachen wir den Wert von Sender in einer lokalen Variablen zu garantieren, dass wir PipeTo an den richtigen IActorRef, wenn es ausführt, sind mit dem Ziel.