func startTCPServer()

in src/tcp/tcpserver.go [56:71]

• 13 lines of code
• 2 McCabe index (conditional complexity)

func startTCPServer(ctx context.Context, streamingProxyAddr string) (*SocketsServer, error) {
	listener, err := net.Listen("tcp", streamingProxyAddr+":0")
	if err != nil {
		return nil, errors.New("Error starting TCP server")
	}

	s := &SocketsServer{
		ctx:            ctx,
		listener:       listener,
		StreamDataChan: make(chan []byte),
	}

	go s.acceptConnections()

	return s, nil
}