* Added null check - the proto suggests this shouldn't ever be null, but there's an issue reporting as much, so this fixes that
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Removed the Task.WhenAll making the operation non-blocking
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Added unit test to validate that the subscription is no longer blocking
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Removed unused line from previous test, added another test
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Added another test
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* More unit tests
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Added more unit tests
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Updated to make DaprPublishSubscribeClientBuilder configurable via a registered IConfiguration
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Added missing copyright statements
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Added missing package reference
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Fixed bad reference (missed in merge)
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Fixed failing unit test
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Tweak to only pass along EventMessage payloads to developers as it's expected that the initial response will be null if EventMessage is populated
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Was missing assignment of the Data property in the TopicMessage. Shout out to both @tommorvolloriddle and @Aimless321 for catching this!
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Fix - return would be bad. Continue is the right move.
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Added a simple test
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Fixed unit tests
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* Merged in tweaks from #1422
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
---------
Signed-off-by: Whit Waldo <whit.waldo@innovian.net>
* 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>
Whit Waldo