Leave a constructor to set threadpool name
call onComplete after all consumers
Add consumer support to groovy reactor builder