Ything-RepoMirrors/rqlite
1
0
Fork 0
mirror of https://github.com/rqlite/rqlite.git synced 2026-01-25 04:16:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix typo in comment

Browse Source
This commit is contained in:
Philip O'Toole
2025-05-20 13:17:05 +01:00
committed by GitHub
parent 90ff019119
commit 384c45708f
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
queue/queue.go
View File

@@ -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 {