ios/io.neuralheads.kmpworker.ios/FlowWrapper

FlowWrapper

class FlowWrapper<T : Any>(flow: Flow<T>)

Wraps a Kotlin Flow for easy consumption from Swift.

Swift cannot directly consume Kotlin Flows. This wrapper provides a callback-based API that Swift can use natively.

// Swift usage:
let wrapper = FlowWrapper(flow: kmpWorker.observe(taskId: "sync"))
wrapper.collect { state in
    print("State: \(state)")
}

// Stop collecting:
wrapper.cancel()

Parameters

flow

The Kotlin Flow to wrap.

Constructors

FlowWrapper

constructor(flow: Flow<T>)

Properties

isActive

val isActive: Boolean

Returns true if the wrapper is actively collecting.

Functions

cancel

fun cancel()

Stops collecting the flow.

collect

fun collect(onEach: (T) -> Unit, onComplete: () -> Unit? = null, onError: (Throwable) -> Unit? = null)

Starts collecting the flow and calls onEach for every emitted value. Call cancel to stop collecting.