anchor.diff:            last = undefined :: non_neg_integer() | undefined,
             max_diff = 1 :: pos_integer(),
             dict, % :: bkt_dict:bkt_dict(),
  -          hpts = false :: boolean(),
  -          dict_mod = bkt_dict
  +          hpts = false :: boolean()
           }).
   
   
  
positive.code:                         State#sstate{recv_size = max(0, Size - 512)},
                          {incomplete, Acc});
          {error, closed} ->
              DictMod:flush(State#sstate.dict),
              ok;
          E ->
              error(E, Transport, Socket, State)
  
negative.code:     end.
  
  error(E, Transport, Socket, #sstate{
                                 dict = Dict}) ->
      lager:error("[tcp:stream] Error: ~p~n", [E]),
      bkt_pdict:flush(Dict),
      ok = Transport:close(Socket).
  get_events(_Bucket, _Filter, [], Socket, Transport, State) ->
      Transport:send(Socket, dproto_tcp:encode(events_end)),
  