Blocking-queue Packages

Calls a callback before size would be exceeded or when count limit is reached

Set of classes used for async prefetching with backpressure (IterableMapper) and async flushing with backpressure (IterableQueueMapper, IterableQueueMapperSimple)