Increment Stream.refs when sending a push promise

michaelbeaumont · seanmonstar · commit d3c2bba18b0e · 2020-08-17T15:54:47.000-07:00
diff --git a/src/proto/streams/streams.rs b/src/proto/streams/streams.rs
@@ -1005,6 +1005,7 @@ impl<B> StreamRef<B> {
             return Err(err.into());
         }
 
+        me.refs += 1;
         let opaque =
             OpaqueStreamRef::new(self.opaque.inner.clone(), &mut me.store.resolve(child_key));
 

Original file line number	Diff line number	Diff line change
`@@ -1005,6 +1005,7 @@ impl<B> StreamRef<B> {`
`1005`	`1005`	`return Err(err.into());`
`1006`	`1006`	`}`
`1007`	`1007`
	`1008`	`+ me.refs += 1;`
`1008`	`1009`	`let opaque =`
`1009`	`1010`	`OpaqueStreamRef::new(self.opaque.inner.clone(), &mut me.store.resolve(child_key));`
`1010`	`1011`