Open.ChannelExtensions
Open.ChannelExtensions copied to clipboard
Can this library be used with Persistent channel
hi,
I am trying to figure out, if this extension library be used with persistent channel from dotnext libraries? https://dotnet.github.io/dotNext/features/threading/channel.html
My primary usage is for unbounded channel with never ending stream of incoming messages, which will need to go through couple of transformations using PipeAsync feature of this extension library to apply required transformations. My main problem is to ensure memory growth of the app is capped, while continuing to use unbounded channel and second is message recovery, if app crashes.
So wanted to check if I use this library will the interim channels used also leverage persistent channel and not normal in-memory channel?
Thanks!