Untitled.kt

# coroutines

[damian]

Untitled.kt

Untitled.kt

[Marko Mitic]

I guess some lock would work but it might be more appropriate for component itself to suspend until ready for more work, at least in given example

[damian]

The other component is a C++ dynamic lib via JNI interface

[Marko Mitic]

do you get a callback when it's ready for more data or do you have to check a flag?

[damian]

I get a callback

[Marko Mitic]

You could use a Mutex or Semaphore

[damian]

Thanks! I will look into that

[Marko Mitic]

channel.consumeEach {
        //bit strange but avoids potential deadlock if callback happens on this thread (as Mutex is not reentrant lock)
        mutex.lock()
		mutex.unlock()

        processResults(it)
    }
	
onNotReady() {
	mutex.lock()
}

onReady() {
	mutex.unlock()
}