[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?

Have you check whether it's still active?

both tested, that's not the problem unfortunately

probably because of this

val inputStream = bluetoothSocket!!.inputStream

having a null value

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

which one? @Lilly

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

ah sure