From 9757ad62f2749a0c662f8f0520d888fe99b342e4 Mon Sep 17 00:00:00 2001 From: Lucas Clemente Date: Mon, 18 Apr 2016 14:08:56 +0200 Subject: [PATCH] add stream.Close --- stream.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/stream.go b/stream.go index a770f7e9..2315767b 100644 --- a/stream.go +++ b/stream.go @@ -81,6 +81,14 @@ func (s *Stream) Write(p []byte) (int, error) { return len(p), nil } +func (s *Stream) Close() error { + return s.Session.SendFrame(&frames.StreamFrame{ + StreamID: s.StreamID, + Offset: s.WriteOffset, + FinBit: true, + }) +} + // AddStreamFrame adds a new stream frame func (s *Stream) AddStreamFrame(frame *frames.StreamFrame) error { s.StreamFrames <- frame