anchor.diff:      {Buffer, State}.
   
   
  +%% @doc Append Data to the appropriate buffer, calling the given
  +%% callback for each packet.
   -spec process_data(binary(), non_neg_integer(),
                      fun((binary(), #state{}) -> #state{}), #state{}) -> #state{}.
   process_data(Data, Elem, CB, State) ->
  
positive.code:                 State
          end,
      ok = gen_tcp:send(Downstream, Packet),
      State1.
  
  
  validate_vbucket(VBucket, VBuckets) ->
  
negative.code:                                   _ -> VBuckets
                                end),
                     last_seen=now(),
                     opcode_counts=dict:new(),
                     takeover=TakeOver},
      %% Trap exits so we can log
      process_flag(trap_exit, true),
      gen_server:enter_loop(?MODULE, [], State).
  
  
  terminate(_Reason, State) ->
      ?log_info("Opcode counts: ~p", [dict:to_list(State#state.opcode_counts)]),
      ok.
  
  
  