added callback for processing snapshots as stream