gr1ffon/quic-go
1
0
Fork 0
forked from quic-go/quic-go
Code Pull Requests Activity

Merge pull request #1084 from lucas-clemente/fix-1083

Browse Source 
fix flaky send stream test
This commit is contained in:
Marten Seemann
2018-01-03 09:55:32 +07:00
committed by GitHub
parent ec339f6702 f2a1206c20
commit 843a0786fc
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
send_stream_test.go
View File

@@ -486,13 +486,15 @@ var _ = Describe("Send Stream", func() {
It("says when it has data for sending", func() { It("says when it has data for sending", func() {
mockFC.EXPECT().UpdateSendWindow(gomock.Any()) mockFC.EXPECT().UpdateSendWindow(gomock.Any())
mockSender.EXPECT().onHasStreamData(streamID) mockSender.EXPECT().onHasStreamData(streamID).Times(2) // once for Write, once for the MAX_STREAM_DATA frame
done := make(chan struct{}) done := make(chan struct{})
go func() { go func() {
defer GinkgoRecover() defer GinkgoRecover()
_, _ = str.Write([]byte("foobar")) _, err := str.Write([]byte("foobar"))
Expect(err).ToNot(HaveOccurred())
close(done) close(done)
}() }()
waitForWrite()
str.handleMaxStreamDataFrame(&wire.MaxStreamDataFrame{ str.handleMaxStreamDataFrame(&wire.MaxStreamDataFrame{
StreamID: streamID, StreamID: streamID,
ByteOffset: 42, ByteOffset: 42,