mirror of https://github.com/dapr/dotnet-sdk.git
91ee78aff4
* Building out Dapr.Messaging and test project for streaming pubsub subscriptions Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Added copyright notices Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Minor stylistic updates Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Added generic client builder to support publish/subscribe client builder Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Tweaked XML comment Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Added several unit tests for the generic client builder Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Updated to include latest review changes: - Added lock so that while we guarantee the method is called only once, it should be thread-safe now - Marked PublishSubscribeReceiver as internal so its members aren't part of the public API - Updated TopicMessage to use IReadOnlyDictionary Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Switched to interlock exchange instead of lock to slightly simplify code Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Added sample project Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Minor changes to unit test Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Deleted protos folder Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Using lowercase protos dir name Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Added registration extension methods Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Updated example to use DI registration Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Added default cancellation token Signed-off-by: Whit Waldo <whit.waldo@innovian.net> * Passing stream into method instead of creating it twice Signed-off-by: Whit Waldo <whit.waldo@innovian.net> --------- Signed-off-by: Whit Waldo <whit.waldo@innovian.net> |
||
|---|---|---|
| .. | ||
| Extensions | ||
| Dapr.Common.Test.csproj | ||
| DaprDefaultTest.cs | ||
| DaprGenericClientBuilderTest.cs | ||