octmar

Update: This seems to happen when i'm pushing PartitionedStreamEvent. Changed the registering ingress to: var ingress = container.RegisterPartitionedInput( streamEvents: observable.Synchronize(), partitionExtractor: e => e.IndexId, startEdgeExtractor: e => e.Date.Ticks, flushPolicy: PartitionedFlushPolicy.None,...