diff options
Diffstat (limited to 'pkg/server/queue')
| -rw-r--r-- | pkg/server/queue/queue.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/pkg/server/queue/queue.go b/pkg/server/queue/queue.go index 704d884..f0c1fc9 100644 --- a/pkg/server/queue/queue.go +++ b/pkg/server/queue/queue.go @@ -79,6 +79,10 @@ func (q Q) Dry() { } func (w *writer) Write(p []byte) (int, error) { + if len(p) == 0 { + return 0, nil + } + buf := make([]byte, len(p)) copy(buf, p) w.q <- buf |