1 files changed, 11 insertions, 0 deletions
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
+}