anchor.diff:          end, NewSince, infinity),
       State#{changes_stream => Stream, ref => Ref}.
   
  -%%        {ok, {_, Db}} = couchdb_datastore_driver:get_db(),
  -%%        {ok, Ref} = couchbeam_changes:follow(Db, [continuous, include_docs, {since, 0}]),
  -%%        State#{ref => Ref}.
  -
  -
  -
  -
   %%--------------------------------------------------------------------
   %% @doc
   %% Listens for events and pushes them to the socket
  
positive.code: -spec terminate(Reason :: term(), req(), #{}) -> ok.
  terminate(_, _, #{changes_stream := Stream}) ->
      gen_changes:stop(Stream).
  %%    ok.
  
  %%--------------------------------------------------------------------
  %% @doc @equiv pre_handler:allowed_methods/2
  
negative.code:         {Ref, Change = #change{seq = Seq, doc = Doc, model = Model}} ->
              ?info("CHANGE: ~p", [Change]),
              stream_loop(SendChunk, State)
      after
          Timeout ->
              ok
  