(event *QueueEvent)
| 137 | } |
| 138 | |
| 139 | func (ep *EventPool) putQueueEvent(event *QueueEvent) error { |
| 140 | select { |
| 141 | case ep.events <- event: |
| 142 | return nil |
| 143 | default: |
| 144 | return ErrEventPoolFull |
| 145 | } |
| 146 | } |
| 147 | |
| 148 | func (ep *EventPool) getQueueEvent() *QueueEvent { |
| 149 | select { |
no outgoing calls
no test coverage detected