QueueProcessor

constructor(lifetime: Lifetime, process: suspend (T) -> Unit)