RxJS websocket issue

websocket.js

let candidatesToSend = []
let candidatesReceived = []

let socketSubject = Observable.webSocket({
  url: 'wss://...',
  openObserver: {
    next: e => {
      e.currentTarget.binaryType = 'arraybuffer'
      candidatesToSend.forEach(candidate => {
        console.log('sending candidate', candidate)
        socketSubject.next(candidate)
      })
      candidatesToSend = []
    }
  }
})

candidatesToSend.push({ candidate: 1 })
candidatesToSend.push({ candidate: 2 })

socketSubject.subscribe({
  next: msg => {
    console.log('received candidate', msg)
    candidatesReceived.push(msg)
  }
})

socketSubject.next({ candidate: 3 })

socketSubject.unsubscribe()