anchor.diff:          {ok, #state{socket = Socket} = State1} ->
               case gen_tcp:send(Socket, Req) of
                   ok ->
  -                    NewQueue = [From|State1#state.queue],
  -                    {noreply, State1#state{queue = NewQueue}};
  +                    {noreply, State1#state{pid_from = From}};
                   {error, Reason} ->
                       {reply, {error, Reason}, State1}
               end;
  
positive.code:             Self = self(),
              spawn(fun() -> reconnect_loop(Self, State) end)
      end,
      {noreply, State#state{socket = undefined, queue = []}};
  
  handle_info({connection_ready, Socket}, #state{socket = undefined} = State) ->
      {noreply, State#state{socket = Socket}};
  
negative.code:                    port = Port,
                     reconnect_sleep = ReconnectSleepInterval,
                     nreq = 0,
                     buf = <<>>},
      case connect(State) of
          {ok, NewState} ->
              {ok, NewState};
  