Cleans up stream-messages and changes its behavior to call a handler function, passing it a lazy seq of messages.