Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

C# protoactor - alternative to Akka.NETs pipeto?

In Akka and Akka.Net there is the PipeTo pattern for handling asynchrounous stuff (like I/O) and pipe a message back to the actor´s messagebox. How can that be done in Protoactor?

like image 978
Jonas Jakobsson Avatar asked Nov 02 '17 19:11

Jonas Jakobsson


People also ask

What C is used for?

C programming language is a machine-independent programming language that is mainly used to create many types of applications and operating systems such as Windows, and other complicated programs such as the Oracle database, Git, Python interpreter, and games and is considered a programming foundation in the process of ...

What is the full name of C?

In the real sense it has no meaning or full form. It was developed by Dennis Ritchie and Ken Thompson at AT&T bell Lab. First, they used to call it as B language then later they made some improvement into it and renamed it as C and its superscript as C++ which was invented by Dr.

Is C language easy?

C is a general-purpose language that most programmers learn before moving on to more complex languages. From Unix and Windows to Tic Tac Toe and Photoshop, several of the most commonly used applications today have been built on C. It is easy to learn because: A simple syntax with only 32 keywords.

Is C programming hard?

C is more difficult to learn than JavaScript, but it's a valuable skill to have because most programming languages are actually implemented in C. This is because C is a “machine-level” language. So learning it will teach you how a computer works and will actually make learning new languages in the future easier.


1 Answers

There are two ways to deal with asynchronous actions in Proto.Actor. The first would be to simply await the task as Proto.Actor has full support for async await. But as you might know, this will prevent the actor from processing other messages during the await.

The other alternative, which is similar to PipeTo is ReenterAfter. This does the same as PipeTo but does not send a message but rather triggers a callback:

public Task ReceiveAsync(IContext context)
{
     var task = GetSomeAsyncTask(...);
     context.ReenterAfter(task, t => {
         //code inside here will run when the task completes.
         //still preserving actor concurrency constraints
     });
}

This often makes the code easier to reason about than PipeTo as that forces you to send a message and add another message handler. with ReenterAfter, you get the same effect, still concurrency constrained by the actor, but you can build entire workflows this way.

like image 147
Roger Johansson Avatar answered Sep 22 '22 12:09

Roger Johansson