commit d8de64f83ce613afc3bcdcbcc755480e71891c52 · edavis.dev/bsky-feeds

edavis.dev / bsky-feeds

this repo has no description

fork atom

fix(cmd/mostliked): don't close jetstreamEvents and close websocket first

Eric Davis 1 year ago d8de64f8 276ced5c

options

unified split

Changed files

+1 -2

cmd

mostliked

main.go

+1 -2

cmd/mostliked/main.go

···

       35
       35
        
       	go func(conn *websocket.Conn, dbCnx *sql.DB, jetstreamEvents chan []byte) {

     

       36
       36
        
       		<-signalChan

     

       37
       37
        
       		log.Println("shutting down...")

     

       38
       38
       -
       		close(jetstreamEvents)

     

       38
       38
       +
       		conn.Close()

     

       39
       39
        
       		dbCnx.Close()

     

       40
       40
       -
       		conn.Close()

     

       41
       40
        
       		close(cleanupDone)

     

       42
       41
        
       	}(conn, dbCnx, jetstreamEvents)

     

       43
       42