Support lambdas and Queues.

Add `processed` callback.