Added support for streaming messages to a process

Implemented #8