Cannot subscribe to a system category stream

[DStranger]

I have the system '$by_category' projection running, thus, there's a stream for each category, looking like '$ce-something'. But when I try to subscribe to it, I get an error:

eventstore.tcp.ConnectionActor - Cannot deliver SubscribeToStreamCompleted(9834711395,Some(EventNumber(13))), client not found for correlationId: 55cc4281-00b5-4b17-a591-92ce4d47aab1, unsubscribing

Am I missing something? I'm using version 4.1.1.

[t3hnar]

@DStranger could you please post your code snippet ?

[DStranger]

@t3hnar

val publisher = esConnection
    .streamPublisher(EventStream.Id("$ce-something"), offset)
Source.fromPublisher(publisher)
...

[ahjohannessen]

@DStranger did you try making publisher a def instead of val ?

[shaan1337]

@t3hnar we have a similar case for one of our customers:

[WARN] [07/15/2018 21:36:55.998] [Viewpopulator-akka.actor.default-dispatcher-4] [akka://Viewpopulator/user/$b] Cannot deliver SubscribeToStreamCompleted(12638592751,Some(EventNumber(90))), client not found for correlationId: 64656a85-5fdc-4419-8b10-57eb6fa6f1ab, unsubscribing

do you have any idea about what the issue could be?