surveily / orleans.streaming.grains Goto Github PK

Does this package allow for Fan-Out i.e: multiple consumers can read the same stream message?
Thanks

There is one test scenario which is hanging until Timeout due to MessagesDeliveredAsync not being triggered.

The scenario works as follows: I have implemented FireAndForgetDelivery and I am trying to test it. The GrainsQueueAdapter.QueueMessageBatchAsync() won't return until the MessagesDeliveredAsync triggers and marks the message as completed.

// F&F=false
When_Sending_Compound_Message_One_To_Many 
-> EmitterGrain.SendAsync(text, data) 
    -> CompoundReceiverGrain.OnNext() 
        -> BlobReceiverGrain.OnNext()
        -> SimpleRecevierGrain.OnNext()

The messages are passed all the way to the BlobReceiverGrain.OnNext() but unfortunately it hangs after finishing that method execution. SimpleRecevierGrain.OnNext() is never triggered in the CompoundReceiverGrain.OnNext() due to awaiting the completion of the BlobReceiverGrain.OnNext(), which executes successfuly.

All other tests (F&F on and off) work fine. This one doesn't and I guess its due to two consecutive OnNext invocations in the CompoundReceiverGrain.OnNext().

Please help me trace this issue by either reviewing the code of the PostAsync or by debugging the test case in the .devcontainer.