commit 7a83424cc9891a094489e9f01f7a8e38a160d4c2 · dunkirk.sh/core

dunkirk.sh / core

forked from tangled.org/core

this repo has no description

fork atom

jetstream: force reconnect on error

anirudh.fi 9 months ago 7a83424c 80520d2c

options

unified split

Changed files

jetstream

jetstream.go

jetstream/jetstream.go

···

       115
        
       

     

       116
        
       		if err := j.client.ConnectAndRead(connCtx, cursor); err != nil {

     

       117
        
       			l.Error("error reading jetstream", "error", err)

     

       0
        
       
     

       0
        
       
     

       118
        
       		}

     

       119
        
       

     

       120
        
       		select {

···

       115
        
       

     

       116
        
       		if err := j.client.ConnectAndRead(connCtx, cursor); err != nil {

     

       117
        
       			l.Error("error reading jetstream", "error", err)

     

       118
       +
       			cancel()

     

       119
       +
       			continue

     

       120
        
       		}

     

       121
        
       

     

       122
        
       		select {