Implemented streaming and snapshots