Method startReceiveLoop

http3/client.go:289–305

startReceiveLoop starts datagramReceiveLoop with a given quic.Connection, first checking if it already has been started.

(conn quic.Connection)

// startReceiveLoop starts datagramReceiveLoop with a given quic.Connection, first checking
// if it already has been started.
func (c *Client) startReceiveLoop(conn quic.Connection) error {
	c.logger.Info("startReceiveLoop", "conn", conn)
	c.mutex.Lock()
	defer c.mutex.Unlock()
	if c.receiveLoopStarted {
		return nil
	}

	ctx, cancel := context.WithCancel(context.Background())
	c.datagramCtx = ctx
	c.datagramCancel = cancel

	go c.datagramReceiveLoop(conn)

	c.receiveLoopStarted = true
	return nil
}

func (c *Client) cancelAllUDPStreams() error {
	streamList := []*DatagramStream{}