Support lambdas and Queues.
Add `processed` callback.