vibe.d beta banner
get vibe.d

Asynchronous I/O that doesn’t get in your way, written in D

Function Channel.consumeAll

Attempts to consume all elements currently in the queue.

bool consumeAll (
  ref FixedRingBuffer!(T,buffer_size) dst

bool consumeAll (
  ref FixedRingBuffer!(T,buffer_size) dst
) shared;

This function will block if no elements are available. Once at least one element is available, the contents of dst will be replaced with all available elements.

If the empty property is or becomes true before data becomes avaiable, dst will be left untouched and false is returned.


Sönke Ludwig


© 2017-2019 RejectedSoftware e.K.


Subject to the terms of the MIT license, as written in the included LICENSE.txt file.