mvdan.cc / tangled-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 c524aaa8 3d9837e9

verified
+2 -1
+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