After debugging a while, I figured out, that the communication is hard newline driven.
synchronized(inputStream) {
try {
val receivedString = **reader.readLine()**
if (!TextUtils.isEmpty(receivedString)) {
emitter.onNext(receivedString)
}
} catch (e: Exception) {
if (!emitter.isCancelled && !closed.get()) {
emitter.onError(e)
}
}
My communication requries a # or \r\n as delimiter.
There are several ways to solve this, the easiest and most flexibility providing solution, seems to me, changing from reader.readLine() to a scanner with a regex.
Are you interested in a modification like this ?
After debugging a while, I figured out, that the communication is hard newline driven.
My communication requries a # or \r\n as delimiter.
There are several ways to solve this, the easiest and most flexibility providing solution, seems to me, changing from reader.readLine() to a scanner with a regex.
Are you interested in a modification like this ?