Skip to content

Commit 37fd336

Browse files
committed
fix: closed stream by CANCEL code
1 parent e4cf88c commit 37fd336

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/proto/streams/state.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -431,6 +431,7 @@ impl State {
431431
pub fn ensure_recv_open(&self) -> Result<bool, proto::Error> {
432432
// TODO: Is this correct?
433433
match self.inner {
434+
Closed(Cause::Error(Error::Reset(_, Reason::CANCEL, _))) => Ok(false),
434435
Closed(Cause::Error(ref e)) => Err(e.clone()),
435436
Closed(Cause::ScheduledLibraryReset(reason)) => {
436437
Err(proto::Error::library_go_away(reason))

0 commit comments

Comments
 (0)