Fixes #2 will stop pipe when message is nil

Use nil to indicate pipe should stop processing message.