Estoy usando el cliente Socket.IO y tengo el siguiente código:

 export const notificationsWsSubject = new BehaviorSubject<Socket | null>(null) signedInObservable.pipe( switchMap(user => forkJoin([of(user), from(getNotificationsWebsocketTicket())])) ).subscribe(values => { notificationsWsSubject.next( io(SERVER_URL, { auth: { ticket: values[1].data, accessToken: values[0].accessToken } }) ) })

Básicamente, cada vez que un usuario inicia sesión ( signedInObservable ), solicito un ticket de mi servidor ( getNotificationsWebsocketTicket() ) y solo entonces abro una conexión websocket.

Ahora quiero hacer lo mismo para cuando una conexión se ha cerrado por algún motivo (fuera de línea temporal) y Socket.IO ha intentado volver a conectar.

¿Cómo puedo asegurarme de que Socket.IO intente "reconectarse" solo después de que hice una solicitud a getNotificationsWebsocketTicket() ? para que pueda volver a conectarme con los datos de auth ?

algo como:

 io.beforeReconnect(() => { return getNotificationsWebsocketTicket() }).then(ticket => io(SERVER_URL, { auth: { ticket: ticket accessToken: getToken() }) )