anchor.diff:              {error, Error};
           {tcp, _Sock, <<Bulk/binary>>} ->
               case byte_size(Bulk) of
  -                ?BUFF_SIZE ->
  +                ?BUFFER ->
                       {ok, load_buffer, Bulk};
                   _ ->
                       {ok, load_stream, Bulk}
  
positive.code:                 mode,
                  state,
                  socket,
                  buffer=?BUFF_UNDEF,
                  callback}).
  
  
  
negative.code:     {noreply, S};
  
  handle_info({tcp, Sock, Data}, S = #state{state=stream, mode=sync, buffer=Buffer}) ->
      case buffer(byte_size(Data), Data, Buffer) of
          {ok, NewBuffer} ->
              ok;
          {ok, NewBuffer, Commands, _} ->
              eslaver_utils:callback(S#state.callback, Commands)
      end,
      inet:setopts(Sock, [{active,once}]),
      {noreply, S#state{buffer=NewBuffer}};
  
  handle_info({tcp, Sock, Data}, S = #state{state=stream, mode=psync, buffer=Buffer}) ->
      NewOffset = case buffer(byte_size(Data), Data, Buffer) of
          {ok, NewBuffer} ->
              S#state.offset;
          {ok, NewBuffer, Commands, OffsetSize} ->
              eslaver_utils:callback(S#state.callback, Commands),
              (S#state.offset + OffsetSize)
      end,
      %repl_ack(Sock, NewOffset), % still don't know if putting this here is a good idea
      inet:setopts(Sock, [{active,once}]),
      {noreply, S#state{offset=NewOffset, buffer=NewBuffer}, ?REPL_TIMEOUT};
  
  