marco.tngl.sh / core
forked from tangled.org/core
Monorepo for Tangled
fork atom

wip: fix jetstream client

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

boltless.me 223e92d0 fa470d07

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