Collect as flow

[Nodrex]

Need to add collectSingleAsFlow or just single (cause flow needs to call collect) in parallel to the callback

Will use callbackflow internally

[Nodrex]

fun myDataFlow(): Flow<MyData> = callbackFlow {
    val collector = DataCollector.collectSingle<MyData>(
        onResult = { result, error ->
            if (result != null) {
                // Send the successful result into the flow
                trySend(result)
                // Close the flow since it's a single result
                close() 
            } else {
                // If there's an error, close the flow with an exception
                close(error ?: RuntimeException("Unknown data collection error"))
            }
        }
    )

    // When the flow is cancelled, cancel the underlying data collection
    awaitClose {
        collector.cancel()
    }
}

and this will be the usage

viewModelScope.launch {
    myDataFlow()
        .catch { error -> 
            // Handle any errors from the flow
            Log.d("TAG", "Failed to get data: ${error.message}")
        }
        .collect { myData ->
            // Success!
            Log.d("TAG", "Data received: $myData")
        }
}