+str Add support for actor consumer endpoint

Prototype for discussion. The purpose is to let user implement a `Consumer` as an actor, with full control of backpressure.