mirror of
https://github.com/minio/minio
synced 2024-11-05 17:34:01 +00:00
Correct small typo in pubsub (#18923)
This commit is contained in:
parent
65028d4a35
commit
4cd777a5e0
1 changed files with 2 additions and 2 deletions
|
@ -1,4 +1,4 @@
|
|||
// Copyright (c) 2015-2021 MinIO, Inc.
|
||||
// Copyright (c) 2015-2024 MinIO, Inc.
|
||||
//
|
||||
// This file is part of MinIO Object Storage stack
|
||||
//
|
||||
|
@ -50,7 +50,7 @@ type PubSub[T Maskable, M Maskable] struct {
|
|||
}
|
||||
|
||||
// Publish message to the subscribers.
|
||||
// Note that publish is always nob-blocking send so that we don't block on slow receivers.
|
||||
// Note that publish is always non-blocking send so that we don't block on slow receivers.
|
||||
// Hence receivers should use buffered channel so as not to miss the published events.
|
||||
func (ps *PubSub[T, M]) Publish(item T) {
|
||||
ps.RLock()
|
||||
|
|
Loading…
Reference in a new issue