package stream

func (strm *Streamer) init(streamSize int) {
	// set up error response if context times out/is canceled
	go strm.cancelResponse()

	// start routine to buffer communication between main routine and upload routine
	go strm.bufferRoutine(streamSize)
	if strm.opts.checkOpts != nil {
		go strm.testRoutine(streamSize)
	}

	// connect to server
	var err *CloudError
	if strm.conn, err = strm.opts.connectFn(strm.ctx); err != nil {
		strm.receiver.OnError(err.Kind, err.Err)
		strm.cancel()
		return
	}

	// start routine to upload audio via GRPC until response or error
	go func() {
		responseInited := false
		for data := range strm.audioStream {
			if err := strm.sendAudio(data); err != nil {
				return
			}
			if !responseInited {
				go strm.responseRoutine()
				responseInited = true
			}
		}
	}()
}