pipe api must be called to enable hof chaining on publish messages, updated tests to reflect new api