commit 38f4a7e719e809603707b6b95505bcb6c9c843f5 · edavis.dev/bsky-feeds

edavis.dev / bsky-feeds

this repo has no description

fork atom

fix(mostliked): kill on conn.ReadMessage failure, to trigger restart

Eric Davis 1 year ago 38f4a7e7 70184e95

options

unified split

Changed files

+1 -1

cmd

mostliked

main.go

+1 -1

cmd/mostliked/main.go

···

       53
        
       		for {

     

       54
        
       			_, message, err := conn.ReadMessage()

     

       55
        
       			if err != nil {

     

       56
       -
       				break

     

       57
        
       			}

     

       58
        
       			jetstreamEvents <- message

     

       59
        
       		}

···

       53
        
       		for {

     

       54
        
       			_, message, err := conn.ReadMessage()

     

       55
        
       			if err != nil {

     

       56
       +
       				stop()

     

       57
        
       			}

     

       58
        
       			jetstreamEvents <- message

     

       59
        
       		}