From 4b71b14bd800264c4c920f7a620306e9f46243b2 Mon Sep 17 00:00:00 2001 From: Lucas Clemente Date: Sun, 17 Apr 2016 15:02:12 +0200 Subject: [PATCH] fix stream tests --- stream_test.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/stream_test.go b/stream_test.go index c554e246..ccff520c 100644 --- a/stream_test.go +++ b/stream_test.go @@ -14,7 +14,7 @@ var _ = Describe("Stream", func() { Offset: 0, Data: []byte{0xDE, 0xAD, 0xBE, 0xEF}, } - stream := NewStream(1337) + stream := NewStream(nil, 1337) stream.AddStreamFrame(&frame) b := make([]byte, 4) n, err := stream.Read(b) @@ -32,7 +32,7 @@ var _ = Describe("Stream", func() { Offset: 2, Data: []byte{0xBE, 0xEF}, } - stream := NewStream(1337) + stream := NewStream(nil, 1337) stream.AddStreamFrame(&frame1) stream.AddStreamFrame(&frame2) b := make([]byte, 6) @@ -51,7 +51,7 @@ var _ = Describe("Stream", func() { Offset: 2, Data: []byte{0xBE, 0xEF}, } - stream := NewStream(1337) + stream := NewStream(nil, 1337) stream.AddStreamFrame(&frame1) stream.AddStreamFrame(&frame2) b := make([]byte, 4) @@ -62,7 +62,7 @@ var _ = Describe("Stream", func() { }) It("waits until data is available", func() { - stream := NewStream(1337) + stream := NewStream(nil, 1337) go func() { frame := frames.StreamFrame{ Offset: 0, @@ -86,7 +86,7 @@ var _ = Describe("Stream", func() { Offset: 1, Data: []byte{0xBE, 0xEF}, } - stream := NewStream(1337) + stream := NewStream(nil, 1337) stream.AddStreamFrame(&frame1) err := stream.AddStreamFrame(&frame2) Expect(err).To(HaveOccurred())