anchor.diff:          {Ref, Change = #change{seq = Seq, doc = Doc, model = Model}} ->
               ?info("CHANGE: ~p", [Change]),
               stream_loop(SendChunk, State)
  -%%        {Ref, {done, LastSeq}} ->
  -%%            ?info("CHANGE DONE ~p", [LastSeq]),
  -%%            ok;
  -%%        {Ref, {change, Row}} ->
  -%%            ?info("CHANGE ~p", [Row]),
  -%%            stream_loop(SendChunk, State);
  -%%        {Ref, {error, Msg}} ->
  -%%            ?info("CHANGE ERROR ~p", [Msg]),
  -%%            ok
       after
           Timeout ->
               ok
  
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:         end, NewSince, infinity),
      State#{changes_stream => Stream, ref => Ref}.
  
  %%--------------------------------------------------------------------
  %% @doc
  %% Listens for events and pushes them to the socket
  