[SOLVED] I have a `channelFlow` that stops sending...

# coroutines

[Lilly]

[SOLVED] I have a channelFlow that stops sending to collector after some time and I can't figure out why:

override fun readByteArrayStream(): Flow<ByteArray> = channelFlow {
        try {
            requireNotNull(bluetoothSocket) { "Bluetooth socket is null. Connection has been closed." }

            val inputStream = bluetoothSocket!!.inputStream

            val buffer = ByteArray(1024)

            while (isActive) {
                val numBytes = inputStream.read(buffer)
                val readBytes = buffer.copyOf(numBytes)
                Log.d("Reading", "$readBytes")
                send(readBytes)
            }
        } catch (e: Exception) {
            Log.e("Error", "error: ${e.message}")
        }
    }.flowOn(<http://Dispatchers.IO|Dispatchers.IO>)

It's still logging so the flow didn't stop. Any ideas?

[radityagumay]

Have you check whether it's still active?

[radityagumay]

and shouldn't we add awaitClose()?

[Lilly]

both tested, that's not the problem unfortunately

[Lilly]

This also does not work, when I use flow builder

[Johnjake Talledo]

probably because of this val inputStream = bluetoothSocket!!.inputStream having a null value

[Lilly]

That's also not the problem. readBytes is logged and has data, it just don't send/emit it to the collector

[Lilly]

I could figure it out. Some of the intermediate operators seemed to block the chain

[radityagumay]

which one? @Lilly

[Lilly]

@radityagumay It was a self made operator. I was playing around with timeouts but I discarded the idea

[radityagumay]

ah sure