From de868930e2301b68a50bde088dd83dc575b72c54 Mon Sep 17 00:00:00 2001 From: Mikhail Osipov Date: Sun, 23 Feb 2020 05:20:04 +0300 Subject: prepare to auth --- pkg/server/queue/queue.go | 11 +++++++++++ 1 file changed, 11 insertions(+) (limited to 'pkg/server/queue') diff --git a/pkg/server/queue/queue.go b/pkg/server/queue/queue.go index 8d0f395..745d971 100644 --- a/pkg/server/queue/queue.go +++ b/pkg/server/queue/queue.go @@ -41,6 +41,10 @@ func (q Q) Writer() io.Writer { return &writer{q: q} } +func (q Q) Dry() { + for _ = range q {} +} + func (w *writer) Write(p []byte) (int, error) { buf := make([]byte, len(p)) copy(buf, p) @@ -58,3 +62,10 @@ func IoCopy(r io.Reader, w io.Writer) error { return nil } + +func Copy(rq, wq Q) error { + for b := range rq { + wq <- b + } + return nil +} -- cgit v1.2.3-70-g09d2