Highland/stream-based worker queue