4 references to AppEvent
Nats.ApiService (3)
Program.cs (3)
31
app.MapPost("/publish/", async (
AppEvent
@event, INatsJSContext js) =>
46
await foreach (var msg in consumer.ConsumeAsync<
AppEvent
>(cancellationToken: ct))
66
await foreach (var msg in consumer.ConsumeAsync<
AppEvent
>(cancellationToken: ct))
Nats.Backend (1)
Program.cs (1)
25
await foreach (var msg in nats.SubscribeAsync<
AppEvent
>("events.>", cancellationToken: _cts.Token).ConfigureAwait(false))