Closed bezzad closed 9 years ago
Before do post action, check the block state is not equals by TaskStatus.Faulted
, either not, so create that again.
if (abErrorSaver == null || abErrorSaver.Completion.IsFaulted)
{
abErrorSaver = new ActionBlock<Error>(async e =>
{
... some action codes ...
}, new ExecutionDataflowBlockOptions { MaxMessagesPerTask = 1 });
}
await abErrorSaver.SendAsync(error);
When DataFlow Blocks get to Faulted state, another post massage not work!
My some action blocks when doing some actions , maybe that actions not work actually, so the acrtion block also get to Faulted state and not work for another queue incoming objects...