movement.swift

func movement() async {
    // TODO:  Dont use async version because it hangs!
    GCController.startWirelessControllerDiscovery { }

    while !Task.isCancelled {
        // Wait for any controller to become current
        _ = await NotificationCenter.default.notifications(named: .GCControllerDidBecomeCurrent, object: nil).makeAsyncIterator().next()
        guard let currentController = GCController.current, let gamepad = currentController.extendedGamepad else {
            return
        }
        // Start a task to print all game pad events
        let eventsTask = Task {
            for await element in gamepad.events {
                print(element)
            }
        }
        // Wait for that device to stop being current
        _ = await NotificationCenter.default.notifications(named: .GCControllerDidStopBeingCurrent, object: currentController).makeAsyncIterator().next()
        // Kill the current task
        eventsTask.cancel()
    }

    GCController.stopWirelessControllerDiscovery()
}

extension GCExtendedGamepad {
    enum Event {
        case elementChanged(GCDeviceElement)
    }

    var events: AsyncStream <Event> {
        AsyncStream<Event> { continuation in
            valueChangedHandler = { _, element in
                continuation.yield(.elementChanged(element))
            }
            continuation.onTermination = { @Sendable [weak self] _ in
                self?.valueChangedHandler = nil
            }
        }
    }
}