jet / propulsion

.NET event stream projection and scheduling platform with CosmosDB, DynamoDB, EventStoreDB, MemoryStore, message-db, Equinox and Kafka integrations
https://github.com/jet/dotnet-templates
Apache License 2.0
177 stars 24 forks source link

feat(Scheduler): Abend in RequireAll mode where starved #257

Open bartelink opened 7 months ago

bartelink commented 7 months ago

In RequireAll mode, the Scheduler will sit patiently waiting forever if all the buffered streams in the baches queue are waiting or disordered events

When the MaxReadAhead is drained, there are no active handlers, and there is nothing to dispatch, the system should abend rather than just sitting there.