anchor.diff:          {ok, Val} -> Val
       end.
   
  -buffer(?BUFF_SIZE, Data, Buffer) ->
  +buffer(0, ?EMPTY, ?EMPTY) ->
  +    {ok, ?EMPTY};
  +buffer(1, <<"\n">>, ?EMPTY) ->
  +    {ok, ?EMPTY};
  +buffer(?BUFFER, Data, Buffer) ->
       {ok, bufferize(Data, Buffer)};
  -buffer(_, Data, Buffer) ->
  +buffer(A, Data, Buffer) ->
  +    io:format("mira -> ~p ~p ~p ~n",[A, Data, Buffer]),
       NewData = <<Buffer/binary, Data/binary>>,
  -    {ok, Commands} = redis:parse(NewData), % FIXME?
  -    {ok, ?BUFF_UNDEF, Commands}.
  -
  -bufferize(Data, ?BUFF_UNDEF) ->
  +    {ok, Commands} = redis:parse(NewData), % FIXME
  +    {ok, ?EMPTY, Commands, byte_size(NewData)}.
  +
  +bufferize(Data, ?EMPTY) ->
       Data;
   bufferize(Data, Buffer) ->
  -    <<Buffer/binary, Data/binary>>.+    <<Buffer/binary, Data/binary>>.
  
positive.code:                 mode,
                  state,
                  socket,
                  buffer=?BUFF_UNDEF,
                  callback}).
  
  
  
negative.code: 
  -define(BS, <<" ">>). % Binary blank space
  -define(CRLF, <<"\r\n">>).
  -define(BUFFER, 1024). % Default buffer size
  -define(EMPTY, <<>>).
  
  %% Heartbeat for psync repl
  -define(REPL_TIMEOUT, 1000).
  