Skip to content
This repository has been archived by the owner on Oct 29, 2023. It is now read-only.

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
david415 committed Oct 10, 2018
1 parent 34d9fbd commit e57ca63
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions session/queue.go
Expand Up @@ -67,7 +67,7 @@ func (q *Queue) Push(e *MessageRef) error {
// upon success, otherwise an error is returned.
func (q *Queue) Pop() (*MessageRef, error) {
if q.len <= 0 {
return nil, QueueEmptyError
return nil, ErrQueueEmpty
}
result := q.content[q.readHead]
q.content[q.readHead] = MessageRef{}
Expand All @@ -80,7 +80,7 @@ func (q *Queue) Pop() (*MessageRef, error) {
// modifying the queue.
func (q *Queue) Peek() (*MessageRef, error) {
if q.len <= 0 {
return nil, QueueEmptyError
return nil, ErrQueueEmpty
}
result := q.content[q.readHead]
return &result, nil
Expand Down

0 comments on commit e57ca63

Please sign in to comment.