Replies: 1 comment · 2 replies
-
|
Hi, post author here. We can receive such notifications from the To protect any task with this, we can write That is quite the old post by the way. I suggest reading about support for I have a couple of examples here including usage as an async queue, broadcast or rewindable stream. The original pattern is still more powerful yet it's now overkill for most use cases. |
Beta Was this translation helpful? Give feedback.
-
|
Great! many thanks! will look into those topics |
Beta Was this translation helpful? Give feedback.
-
|
I've been doing some experiments with IAsyncEnumerable and it seems to be a good fit to stream data from one grain to another, but as far as I can tell, I am missing the back-pressure handling part. The context is that I eventually need to deliver state updates to a web application. I plan to use Signalr, and I see that it supports streaming via IAsyncEnumerable, but the sever would be pushing updates at its own peace instead of the client requesting them when it is ready to handle them. Is there any way around this without using client initiated polling? |
Beta Was this translation helpful? Give feedback.
Uh oh!
There was an error while loading. Please reload this page.
-
Hi, I am implementing something like this https://outcompute.com/2019/05/26/latency-adaptive-real-time-with-reactive-caching-on-microsoft-orleans/ based on the samples from 3.x branch.
Is there any way to receive a notification in a grain that the silo is requested to be shut down? I would like to use this to cancel the long-poll async waiting task as soon as possible in order to let the grain be deactivated and the silo shut down quickly.
I understand that OnDeactivateAsync won't get called until pending requests are completed (I tested this and it makes sense) and in this case I have the long-poll one preventing that.
Beta Was this translation helpful? Give feedback.
All reactions