tjh.dev / core
forked from tangled.org/core
this repo has no description
fork atom

wip: fix jetstream client

Signed-off-by: Seongmin Lee <git@boltless.me>

boltless.me c70617eb 5e6ca2bd

verified
+2 -1
unified split
+2 -1
jetstream/jetstream.go
··· 159 j.cancelMu.Unlock() 160 161 if err := j.client.ConnectAndRead(connCtx, cursor); err != nil { 162 - l.Error("error reading jetstream", "error", err) 163 cancel() 164 continue 165 } 166
··· 159 j.cancelMu.Unlock() 160 161 if err := j.client.ConnectAndRead(connCtx, cursor); err != nil { 162 + l.Error("error reading jetstream, retry in 3s", "error", err) 163 cancel() 164 + time.Sleep(3 * time.Second) 165 continue 166 } 167