From bd5339bff8bf5f5e877e94dfef265a22570a69c7 Mon Sep 17 00:00:00 2001 From: Mikhail Osipov Date: Mon, 17 Feb 2020 11:56:43 +0300 Subject: first working version --- pkg/server/queue/queue.go | 60 +++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 60 insertions(+) create mode 100644 pkg/server/queue/queue.go (limited to 'pkg/server/queue/queue.go') diff --git a/pkg/server/queue/queue.go b/pkg/server/queue/queue.go new file mode 100644 index 0000000..8d0f395 --- /dev/null +++ b/pkg/server/queue/queue.go @@ -0,0 +1,60 @@ +package queue + +import ( + "io" +) + +type Q chan []byte + +type reader struct { + b []byte + q Q +} + +type writer struct { + q Q +} + +func New() Q { + return make(Q) +} + +func (q Q) Reader() io.Reader { + return &reader{q: q} +} + +func (r *reader) Read(p []byte) (int, error) { + if len(r.b) == 0 { + r.b = <-r.q + if r.b == nil { + return 0, io.EOF + } + } + + n := copy(p, r.b) + r.b = r.b[n:] + + return n, nil +} + +func (q Q) Writer() io.Writer { + return &writer{q: q} +} + +func (w *writer) Write(p []byte) (int, error) { + buf := make([]byte, len(p)) + copy(buf, p) + w.q <- buf + + return len(p), nil +} + +func IoCopy(r io.Reader, w io.Writer) error { + if _, err := io.Copy(w, r); err != nil { + if err != io.EOF { + return err + } + } + + return nil +} -- cgit v1.2.3-70-g09d2