Fix up dumb mistakes
Our logged catch is still terminating the stream, move it inside the SelectMany
Add support for deserializing BSON