diff --git a/channelqueue_test.go b/channelqueue_test.go index fffa14c..7302ad2 100644 --- a/channelqueue_test.go +++ b/channelqueue_test.go @@ -232,7 +232,7 @@ func TestRing(t *testing.T) { } } -func TestRingOne(t *testing.T) { +func TestOneRing(t *testing.T) { ch := cq.NewRing[rune](1) for _, r := range "hello" { ch.In() <- r diff --git a/doc.go b/doc.go index 78b811a..684fae8 100644 --- a/doc.go +++ b/doc.go @@ -1,10 +1,9 @@ // Package channelqueue implements a queue that uses channels for input and -// output to provide concurrent access to a re-sizable queue. -// -// This allows the queue to be used like a channel. Closing the input channel -// closes the output channel when all queued items are read, consistent with -// channel behavior. In other words channelqueue is a dynamically buffered -// channel with up to infinite capacity. +// output to provide concurrent access to a re-sizable queue. This allows the +// queue to be used like a channel. Closing the input channel closes the output +// channel when all queued items are read, consistent with channel behavior. In +// other words channelqueue is a dynamically buffered channel with up to +// infinite capacity. // // ChannelQueue also supports circular buffer behavior when created using // `NewRing`. When the buffer is full, writing an additional item discards the