Web/ForgeTrust.Runnable.Web.RazorWire/Streams/InMemoryRazorWireStreamHub.cs
InMemoryRazorWireStreamHub
Type
InMemoryRazorWireStreamHub
Provides an in-memory implementation of using for message distribution.
Method
PublishAsync(string, string)
Publishes a message to all subscribers of the specified channel. Any subscribers that are closed or unable to accept the message are removed during the process.
Method
Subscribe(string)
Subscribes to a named channel and returns a reader that receives messages published to that channel.
The subscription uses an in-memory bounded buffer with capacity 100 that drops the oldest messages when full.
Method
Unsubscribe(string, ChannelReader<string>)
Unregisters a subscriber from the specified channel and completes its associated writer.