| ... | @@ -1107,7 +1107,7 @@ pub const Session = struct { | ... | @@ -1107,7 +1107,7 @@ pub const Session = struct { |
| 1107 | return error.ReadFailed; | 1107 | return error.ReadFailed; |
| 1108 | }) { | 1108 | }) { |
| 1109 | .flush => return error.EndOfStream, | 1109 | .flush => return error.EndOfStream, |
| 1110 | .data => |data| if (data.len > 1) switch (@as(StreamCode, @enumFromInt(data[0]))) { | 1110 | .data => |data| switch (@as(StreamCode, @enumFromInt(data[0]))) { |
| 1111 | .pack_data => { | 1111 | .pack_data => { |
| 1112 | input.toss(1); | 1112 | input.toss(1); |
| 1113 | fs.remaining_len = data.len - 1; | 1113 | fs.remaining_len = data.len - 1; |
| ... | @@ -1117,7 +1117,9 @@ pub const Session = struct { | ... | @@ -1117,7 +1117,9 @@ pub const Session = struct { |
| 1117 | fs.err = error.ProtocolError; | 1117 | fs.err = error.ProtocolError; |
| 1118 | return error.ReadFailed; | 1118 | return error.ReadFailed; |
| 1119 | }, | 1119 | }, |
| 1120 | else => {}, | 1120 | else => { |
| | 1121 | input.toss(data.len); |
| | 1122 | }, |
| 1121 | }, | 1123 | }, |
| 1122 | else => { | 1124 | else => { |
| 1123 | fs.err = error.UnexpectedPacket; | 1125 | fs.err = error.UnexpectedPacket; |