From a82a1a5627131d8cbc087895515978010b7ca293 Mon Sep 17 00:00:00 2001 From: Andy Wang Date: Sun, 12 Apr 2020 11:34:04 +0100 Subject: [PATCH] writerTo --- internal/multiplex/streamBuffer.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/internal/multiplex/streamBuffer.go b/internal/multiplex/streamBuffer.go index 1d2600e..d171b36 100644 --- a/internal/multiplex/streamBuffer.go +++ b/internal/multiplex/streamBuffer.go @@ -13,6 +13,7 @@ package multiplex import ( "container/heap" "fmt" + "io" "sync" "time" ) @@ -96,6 +97,10 @@ func (sb *streamBuffer) Read(buf []byte) (int, error) { return sb.buf.Read(buf) } +func (sb *streamBuffer) WriteTo(w io.Writer) (int64, error) { + return sb.buf.WriteTo(w) +} + func (sb *streamBuffer) Close() error { return sb.buf.Close() }