Skip to content

Commit

Permalink
Various fixes and typos
Browse files Browse the repository at this point in the history
  • Loading branch information
mpiraux committed Mar 24, 2019
1 parent 2051e5b commit 1176915
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion agents/qpack_agent.go
Original file line number Diff line number Diff line change
Expand Up @@ -161,7 +161,7 @@ func (a *QPACKAgent) Run(conn *Connection) {
}
}()

if a.DisableStreams {
if !a.DisableStreams {
conn.Streams.Send(a.EncoderStreamID, []byte{'H'}, false)
conn.Streams.Send(a.DecoderStreamID, []byte{'h'}, false)
}
Expand Down
2 changes: 1 addition & 1 deletion streams.go
Original file line number Diff line number Diff line change
Expand Up @@ -185,7 +185,7 @@ func (s *Stream) addToRead(f *StreamFrame) { // TODO: Flag implementations that
}
}

if s.ReadOffset == s.ReadCloseOffset {
if s.ReadOffset == s.ReadCloseOffset && !s.ReadClosed {
s.ReadClosed = true
s.ReadChan.Close()
}
Expand Down

0 comments on commit 1176915

Please sign in to comment.