Skip to content

Commit 411461f

Browse files
author
mappedbus
committed
Merge branch 'master' of https://github.com/caplogic/mappedbus
2 parents 29351fc + 82b2dfb commit 411461f

File tree

1 file changed

+2
-8
lines changed

1 file changed

+2
-8
lines changed

README.md

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -47,10 +47,7 @@ writer.write(priceUpdate);
4747

4848
// read messages
4949
while (true) {
50-
if (reader.hasNext()) {
51-
if (!reader.next()) {
52-
continue; // message was rolled back, skip it
53-
}
50+
if (reader.next()) {
5451
int type = reader.readType();
5552
if (type == 0) {
5653
reader.readMessage(priceUpdate)
@@ -68,10 +65,7 @@ writer.write(buffer, 0, buffer.length);
6865

6966
// read buffers
7067
while (true) {
71-
if (reader.hasNext()) {
72-
if (!reader.next()) {
73-
continue; // message was rolled back, skip it
74-
}
68+
if (reader.next()) {
7569
int length = reader.read(buffer, 0);
7670
}
7771
}

0 commit comments

Comments
 (0)