dequeueMessage removes and returns the first message from the queue. Returns "" if the queue is empty.
()
| 1000 | // dequeueMessage removes and returns the first message from the queue. |
| 1001 | // Returns "" if the queue is empty. |
| 1002 | func (cli *ChatCLI) dequeueMessage() string { |
| 1003 | cli.messageQueueMu.Lock() |
| 1004 | defer cli.messageQueueMu.Unlock() |
| 1005 | |
| 1006 | if len(cli.messageQueue) == 0 { |
| 1007 | return "" |
| 1008 | } |
| 1009 | |
| 1010 | msg := cli.messageQueue[0] |
| 1011 | cli.messageQueue = cli.messageQueue[1:] |
| 1012 | return msg |
| 1013 | } |
| 1014 | |
| 1015 | func (cli *ChatCLI) Start(ctx context.Context) { |
| 1016 | cli.sessionCtx = ctx |
no test coverage detected