diff options
| author | Mikhail Osipov <mike.osipov@gmail.com> | 2020-02-27 19:38:31 +0300 |
|---|---|---|
| committer | Mikhail Osipov <mike.osipov@gmail.com> | 2020-02-28 03:53:22 +0300 |
| commit | e9bf22ae73b50bf7e72664bd7e71daedacbac9b6 (patch) | |
| tree | f254d6de4e4b13ea6a77c19ab647fbc207dda43e /pkg/server/queue | |
| parent | 27e13f14f4dba71b417ea530bfe035adbd8f0a93 (diff) | |
add zip module
Diffstat (limited to 'pkg/server/queue')
| -rw-r--r-- | pkg/server/queue/queue.go | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/pkg/server/queue/queue.go b/pkg/server/queue/queue.go index 4b69e3a..71f914c 100644 --- a/pkg/server/queue/queue.go +++ b/pkg/server/queue/queue.go @@ -37,6 +37,14 @@ func (r *reader) Read(p []byte) (int, error) { return n, nil } +func (r *reader) ReadByte() (byte, error) { + var b [1]byte + + _, err := r.Read(b[:]) + + return b[0], err +} + func (r *reader) WriteTo(w io.Writer) (int64, error) { if writer, ok := w.(*writer); ok { if len(r.b) > 0 { |