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.