I don't want to duplicate the message on another channel, as ChannelMessageQueue already uses Channel internally, and ChannelReader in particular implemented this: https://learn.microsoft.com/en-us/dotnet/api/system.threading.channels.channelreader-1.readallasync?view=net-7.0