lib/modules: Re-implement queue_rw.go without depending on upcqueue.
I would like to move upcqueue back to internal. I think the new implementation
is simpler and more correct. The previous implementation had the rather
odd semantic that writing a zero-byte slice closed the queueRW.
Change-Id: Ie2e96dcca6b8c78afdb1cf9fc0fec958d8fd92c4
diff --git a/lib/modules/queue_rw_test.go b/lib/modules/queue_rw_test.go
index 26f6f19..f38c7ff 100644
--- a/lib/modules/queue_rw_test.go
+++ b/lib/modules/queue_rw_test.go
@@ -28,8 +28,7 @@
break
}
}
- // This marks EOF.
- if _, err := q.Write([]byte{}); err != nil {
+ if err := q.Close(); err != nil {
t.Fatalf("err %v", err)
}
readData := make([]byte, 0, size)
