alef 0.23.35

Opinionated polyglot binding generator for Rust libraries
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

public func {{ function_name }}({{ params }}) async throws -> AsyncThrowingStream<{{ item_type }}, Error> {
    let handle = try await Task.detached(priority: .userInitiated) {
        try RustBridge.{{ start_fn }}({{ owner_arg }}{{ call_args }})
    }.value

    return AsyncThrowingStream<{{ item_type }}, Error> { continuation in
        let task = Task.detached(priority: .userInitiated) {
            do {
                while !Task.isCancelled {
                    let json = try handle.next().toString()
                    if json.isEmpty { break }
{{ chunk_decode }}                    continuation.yield(chunk)
                }
                continuation.finish()
            } catch {
                continuation.finish(throwing: error)
            }
        }
        continuation.onTermination = { _ in task.cancel() }
    }
}