Pipe a stream of objects for bulk update/insert into MongoDB