[streaming] Implemented mock persistent layer