Model the .NET BroadcastQueue

[dsgrieve]

.NET has a class called BroadcastQueue which orchestrates the updating of ChatHistory from channels (assistant threads). We can model this in reactive streams (project reactor).

1. Understand the .NET BroadcastQueue and how it works to sync history among AgentChannels
2. Model this in reactive streams.
3. Provide unit tests.

Done is defined as

1. Having the API for Agent, AgentChannel, and ChatHistory necessary to support updating chat history from multiple sources in an asynchronous fashion.
2. Having a sample of unit tests that exercise the BroadcastQueue functionality.

Tasks

Beta Give feedback

1. Understand the .NET BroadcastQueue #186
   +0
2. Model BroadcastQueue in Java reactive streams #187
   +0
3. Modify Agent/AgentChannel to use BroadcastQueue #188
   +0
4. Provide unit tests for BroadcastQueue functionality #189
   +0