docs: add wiki how to install

yudhasubki · Dec 11, 2023 · 722e29a · 722e29a
1 parent 3f5db02
commit 722e29a
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 6 deletions.
diff --git a/blockqueue.go b/blockqueue.go
@@ -170,9 +170,6 @@ func (q *BlockQueue[V]) ReadSubscriber(ctx context.Context, topic core.Topic, su
 }
 
 func (q *BlockQueue[V]) getJob(topic core.Topic) (*Job[V], bool) {
-	q.mtx.RLock()
-	defer q.mtx.RUnlock()
-
 	job, exist := q.jobs[topic.Name]
 	if !exist {
 		return &Job[V]{}, false

diff --git a/job.go b/job.go
@@ -219,9 +219,6 @@ func (job *Job[V]) Enqueue(ctx context.Context, topic core.Topic, subscriberName
 }
 
 func (job *Job[V]) getListeners(subscriberId uuid.UUID) (*Listener[V], bool) {
-	job.mtx.RLock()
-	defer job.mtx.RUnlock()
-
 	listener, exist := job.listeners[subscriberId]
 	if !exist {
 		return listener, false