introduce Subscriber which maintains id and snapshot.
start working on a primitive ActiveRecord Channel implementation.