I have a bit of code that does something like this:
conn.SubscribeToAllFrom(null, true, (s,e) => o.OnNext(e), s => o.OnCompleted(), (s,sr,e) => o.OnCompleted(), cred);
This seems to work as expected on a test ES db.
However, on our production ES instance it stops reading some way through it. The exception I get is a RetriesLimitReachedException. Turning on client logging, I see we time out with the following errors:
[18,21:25:45.525,ERROR] EventStoreConnection ‘ES-d107f09e-5b03-4b61-a1da-e437ecd667e5’: operation never got response from server.
UTC now: 21:25:45.523, operation: Operation ReadAllEventsForwardOperation ({321f90ff-f26c-47d9-8ff4-0f7930a69a07}): Position: 263666490/263666490, MaxCount: 500, ResolveLinkTos: True, RequireMaster: True, retry count: 0, created: 21:25:38.469, last updated: 21:25:38.469.
On the server I see errors like:
[27824,06,21:25:45.540] Error while wrapping message EventStore.Core.Messages.ClientMessage+ReadAllEventsForwardCompleted.
Object reference not set to an instance of an object.
Is there something wrong with the data written to ES, a bug, or am I doing things incorrectly?
Thanks,
Karl