diff --git a/queue/queue.go b/queue/queue.go
index 3e7f2aee..58294c9f 100644
--- a/queue/queue.go
+++ b/queue/queue.go
@@ -125,7 +125,7 @@ func New[T any](maxSize, batchSize int, t time.Duration) *Queue[T] {
 // c is an optional channel. If non-nil, it will be closed when the Request
 // containing these objects is closed. Normally this close operation should
 // be called by whatever is processing the objects read from the queue, to
-// indicate that the objects have been processed. The canoncial use of this
+// indicate that the objects have been processed. The canonical use of this
 // is to allow the caller to block until the objects are processed.
 func (q *Queue[T]) Write(objects []T, c FlushChannel) (int64, error) {
 	select {