Sample code for Stream API using TwitterAPIKit.

Stream.swift

func testExample() throws {

    let client = TwitterAPIKit(
        .bearer(
            "token"
        ))

    let exp = expectation(description: "")

    let task = client.v2.sampleStream(.init())
    Task {
        for await response in task.streamResponse(queue: .global(qos: .default)) {
            print(response.prettyString)

            if response.isError {
                exp.fulfill()
                break
            }
        }
    }

    DispatchQueue.main.asyncAfter(deadline: .now() + .seconds(20)) {
        task.cancel()
    }

    wait(for: [exp], timeout: 10000)
}