Fix comment on WithBufferSize (#5)

Author: gammazero

dsqueue.go

@@ -153,7 +153,6 @@ func (q *DSQueue) worker(ctx context.Context, bufferSize, dedupCacheSize int, id
 			if err := q.ds.Put(ctx, k, nil); err != nil {
 				log.Errorw("failed to write item to datastore", "err", err, "qname", q.name)
 			}
-			counter++
 		}
 		if inBuf.Len() != 0 {
 			err := q.commitInput(ctx, counter, &inBuf)
@@ -219,6 +218,7 @@ func (q *DSQueue) worker(ctx context.Context, bufferSize, dedupCacheSize int, id
 				// the input buffer.
 				item = inBuf.PopFront()
 				k = makeKey(item, counter)
+				counter++
 			}
 		}
 

option.go

@@ -39,8 +39,9 @@ func getOpts(opts []Option) config {
 
 // WithBufferSize sets the limit on number of items kept in input buffer
 // memory, at which they are all written to the datastore. A value of 0 means
-// items are only written to the datastore at shutdown, and read from the
-// datastore at start.
+// the buffer size is unlimited, and items are only written to the datastore
+// when the queue has been idle more then the idle write time or when the queue
+// is closed.
 func WithBufferSize(n int) Option {
 	return func(c *config) {
 		if n < 0 {