anchor.diff:                     ip = IP,
                      port = Port,
                      reconnect_sleep = ReconnectSleepInterval,
  +                   buf = <<>>,
                      queue = []},
       case connect(State) of
           {ok, NewState} ->
  
positive.code:     {noreply, State}.
  
  
  handle_info({tcp, Socket, Bs}, State) ->
      Res = recv(Socket, Bs),
      case Res of
          {recv_error, Cause} ->
              {stop, Cause, State};
          _Other ->
              inet:setopts(Socket, [{active, once}]),
              {noreply, handle_response(Res, State)}
      end;
  handle_info({tcp_error, _Socket, _Reason}, State) ->
      {noreply, State};
  
negative.code:           port   :: integer(),
            socket :: reference()|undefined,
            reconnect_sleep :: integer(),
            buf    :: binary(),
            queue = [] :: list()
           }).
  
  