issue.txt

https://github.com/openwebnet/rx-openwebnet/pull/9/files
https://github.com/dendeps/rx-openwebnet/commit/9b1b2de70060dfc9d45fb3ae1ced11c873b407e5

# lib/src/main/java/com/github/niqdev/openwebnet/OpenWebNetObservable.java

```
static Func1<OpenContext, Observable<String>> read() {
    return context -> {
        try {
            ByteBuffer buffer = context.getEmptyBuffer();
            SocketChannel channel = context.getClient();
            Integer count = 1;
            String message = "";

            while(count >0 && !message.contains(ACK)) {
                int length = message.length();
                count = channel.read(buffer);
                message = new String(buffer.array()).trim();
                log(String.format("read: %d|%s", count, message.substring(length)));
            }

            return Observable.just(message);
        } catch (IOException e) {
            return Observable.error(e);
        }
    };
}
```