5 references to AppEvent
Nats.ApiService (3)
Program.cs (3)
42
app.MapPost("/publish/", async (
AppEvent
@event, INatsJSContext jetStream) =>
62
var events = new List<
AppEvent
>();
63
await foreach(var msg in consumer.ConsumeAsync<
AppEvent
>())
Nats.Backend (1)
Program.cs (1)
29
await foreach (var msg in nats.SubscribeAsync<
AppEvent
>("events.>", cancellationToken: _cts.Token).ConfigureAwait(false))
Nats.Common (1)
AppEvent.cs (1)
10
[JsonSerializable(typeof(
AppEvent
))]