diff --git a/lib/std/Io/Threaded.zig b/lib/std/Io/Threaded.zig
index 0f652f44198f1cc13d4009a09039a6fc49fc97e6..1cf715279bc42aa65eeed56636798ac020bcdb86 100644
--- a/lib/std/Io/Threaded.zig
+++ b/lib/std/Io/Threaded.zig
@@ -2877,7 +2877,7 @@ fn batchAwaitConcurrent(userdata: ?*anyopaque, b: *Io.Batch, timeout: Io.Timeout
                                 try poll_storage.add(o.socket_handle, posix.POLL.IN | posix.POLL.ERR);
                                 break :nb;
                             },
-                            else => |e| break .{ e, 0 },
+                            else => |e| break .{ e, msg_i },
                         };
                         data_i += msg.data.len;
                     } else .{ null, o.message_buffer.len } };