Method: Polyphony::Queue#clear

Defined in:
ext/polyphony/queue.c

#clear ⇒ Queue

Removes all values from the queue.

Returns:

  • self



297
298
299
300
301
302
303
304
305
 
# File 'ext/polyphony/queue.c', line 297

VALUE Queue_clear(VALUE self) {
  Queue_t *queue;
  GetQueue(self, queue);

  ring_buffer_clear(&queue->values);
  if (queue->capacity) queue_schedule_blocked_fibers_to_capacity(queue);

  return self;
}