Processing async messages received over a socket with multiple namespaces.

Any async chain really where the steps are in a pipeline