diff --git a/session.go b/session.go index 8d2698b0..0906b40d 100644 --- a/session.go +++ b/session.go @@ -205,17 +205,6 @@ func (s *Session) handleRstStreamFrame(r *bytes.Reader) error { return nil } -// SendFrames sends a number of frames to the client -func (s *Session) SendFrames(frames []frames.Frame) error { - for _, f := range frames { - err := s.SendFrame(f) - if err != nil { - return err - } - } - return nil -} - // SendFrame sends a frame to the client func (s *Session) SendFrame(frame frames.Frame) error { streamframe, ok := frame.(*frames.StreamFrame) diff --git a/stream.go b/stream.go index 2315767b..21255f51 100644 --- a/stream.go +++ b/stream.go @@ -68,12 +68,11 @@ func (s *Stream) ReadByte() (byte, error) { } func (s *Stream) Write(p []byte) (int, error) { - frame := &frames.StreamFrame{ + err := s.Session.SendFrame(&frames.StreamFrame{ StreamID: s.StreamID, Offset: s.WriteOffset, Data: p, - } - err := s.Session.SendFrames([]frames.Frame{frame}) + }) if err != nil { return 0, err } @@ -81,6 +80,7 @@ func (s *Stream) Write(p []byte) (int, error) { return len(p), nil } +// Close imlpements io.Closer func (s *Stream) Close() error { return s.Session.SendFrame(&frames.StreamFrame{ StreamID: s.StreamID,