Added support for no-emit callback and fixed the concurrency counter.