mirror of
https://github.com/refraction-networking/uquic.git
synced 2025-04-05 05:07:36 +03:00
reduce the data size transfered in the mutliplex integration test
This commit is contained in:
parent
ee00cbe088
commit
f82a6a74b5
1 changed files with 3 additions and 2 deletions
|
@ -35,7 +35,7 @@ var _ = Describe("Multiplexing", func() {
|
||||||
str, err := sess.OpenStream()
|
str, err := sess.OpenStream()
|
||||||
Expect(err).ToNot(HaveOccurred())
|
Expect(err).ToNot(HaveOccurred())
|
||||||
defer str.Close()
|
defer str.Close()
|
||||||
_, err = str.Write(testserver.PRDataLong)
|
_, err = str.Write(testserver.PRData)
|
||||||
Expect(err).ToNot(HaveOccurred())
|
Expect(err).ToNot(HaveOccurred())
|
||||||
}()
|
}()
|
||||||
}
|
}
|
||||||
|
@ -51,11 +51,12 @@ var _ = Describe("Multiplexing", func() {
|
||||||
&quic.Config{Versions: []protocol.VersionNumber{version}},
|
&quic.Config{Versions: []protocol.VersionNumber{version}},
|
||||||
)
|
)
|
||||||
Expect(err).ToNot(HaveOccurred())
|
Expect(err).ToNot(HaveOccurred())
|
||||||
|
defer sess.Close()
|
||||||
str, err := sess.AcceptStream(context.Background())
|
str, err := sess.AcceptStream(context.Background())
|
||||||
Expect(err).ToNot(HaveOccurred())
|
Expect(err).ToNot(HaveOccurred())
|
||||||
data, err := ioutil.ReadAll(str)
|
data, err := ioutil.ReadAll(str)
|
||||||
Expect(err).ToNot(HaveOccurred())
|
Expect(err).ToNot(HaveOccurred())
|
||||||
Expect(data).To(Equal(testserver.PRDataLong))
|
Expect(data).To(Equal(testserver.PRData))
|
||||||
}
|
}
|
||||||
|
|
||||||
Context("multiplexing clients on the same conn", func() {
|
Context("multiplexing clients on the same conn", func() {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue