gsadmin/noq
1
0
Fork 0
mirror of https://github.com/n0-computer/noq.git synced 2026-09-25 12:57:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove dead state

Browse Source 
This field was always `true`.
This commit is contained in:
Benjamin Saunders
2021-03-26 16:49:51 -07:00
committed by Dirkjan Ochtman
parent ed164fc458
commit 2cb44d06e4
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quinn-proto/src/connection/streams/recv.rs
+9 -5
View File
@@ -246,8 +246,8 @@ impl<'a> Chunks<'a> {
self.state = ChunksState::Error(e.clone(), st);
return Err(e);
}
ChunksState::Finished(st) => {
self.state = ChunksState::Finished(st);
ChunksState::Finished => {
self.state = ChunksState::Finished;
return Ok(None);
}
ChunksState::Finalized => panic!("must not call next() after finalize()"),
@@ -284,7 +284,7 @@ impl<'a> Chunks<'a> {
ShouldTransmit(false),
max_streams_dirty,
);
self.state = ChunksState::Finished(ShouldTransmit(true));
self.state = ChunksState::Finished;
Ok(None)
} else {
let should_transmit =
@@ -312,7 +312,11 @@ impl<'a> Chunks<'a> {
self.streams.recv.insert(self.id, rs);
should_transmit
}
ChunksState::Finished(should_transmit) | ChunksState::Error(_, should_transmit) => {
ChunksState::Finished => {
debug_assert!(!drop);
ShouldTransmit(true)
}
ChunksState::Error(_, should_transmit) => {
debug_assert!(!drop);
should_transmit
}
@@ -343,7 +347,7 @@ impl<'a> Drop for Chunks<'a> {
enum ChunksState {
Readable(Recv),
Error(ReadError, ShouldTransmit),
Finished(ShouldTransmit),
Finished,
Finalized,
}