Skip to content

Commit

Permalink
Update Subscription docs (remove generic argument in SubscribeAsync) (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
glen-84 authored Jan 12, 2024
1 parent 0a2e0fc commit 635bd79
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -104,7 +104,7 @@ public class SubscriptionType : ObjectType
var receiver = context.Service<ITopicEventReceiver>();

ISourceStream stream =
await receiver.SubscribeAsync<string, Book>("bookAdded");
await receiver.SubscribeAsync<Book>("bookAdded");

return stream;
});
Expand Down Expand Up @@ -346,7 +346,7 @@ public class Subscription
{
public ValueTask<ISourceStream<Book>> SubscribeToBooks(
[Service] ITopicEventReceiver receiver)
=> receiver.SubscribeAsync<string, Book>("ExampleTopic");
=> receiver.SubscribeAsync<Book>("ExampleTopic");

[Subscribe(With = nameof(SubscribeToBooks))]
public Book BookAdded([EventMessage] Book book)
Expand Down

0 comments on commit 635bd79

Please sign in to comment.