Add err stdserializer
Add some better logging
Change stream to use a queue for each()