Skip to content

Commit d9545f4

Browse files
committed
Tweak async socket sequence number emission.
Matches a fix in MoarVM. Enables fixing various data loss bugs.
1 parent 2253c07 commit d9545f4

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/vm/jvm/runtime/org/perl6/nqp/io/AsyncSocketHandle.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -194,8 +194,7 @@ public void completed(Integer numRead, AsyncTaskInstance task) {
194194

195195
try {
196196
if (numRead == -1) {
197-
task.seq = -1;
198-
callback(curTC, task, -1, Str, Null);
197+
callback(curTC, task, task.seq, Str, Null);
199198
} else {
200199
readBuffer.flip();
201200
SixModelObject decoded = decoder.decode(tc, readBuffer, numRead);

0 commit comments

Comments
 (0)