moved search for --end-of-stream to after all other messages parsed from body and moved response.end() to after client.publish() because response.end() kicks off a client.end() so the last chunk of events weren't flowing to listeners. moved to 59 second test for --keep-alive.