anchor.diff:          {value, {_, <<"on">>}}  -> put(datetime_mod, pgsql_idatetime);
           {value, {_, <<"off">>}} -> put(datetime_mod, pgsql_fdatetime)
       end,
  -    notify(State, connected),
  -    {noreply, State#state{handler = on_message,
  -                         txstatus = Status,
  -                         queue = queue:drop(Q)}};
  +    State2 = reply(State#state{handler = on_message,
  +                               txstatus = Status},
  +                   connected),
  +    {noreply, State2};
   
   initializing({error, _} = Error, State) ->
  -    notify(State, Error), 
  -    {stop, normal, State};
  +    {stop, normal, reply(State, Error)};
   
   initializing(Other, State) ->
       on_message(Other, State).
  
positive.code: send(#state{mod = Mod, sock = Sock}, Type, Data) ->
      Mod:send(Sock, pgsql_wire:encode(Type, Data)).
  
  notify(#state{queue = Q}, Message) ->
      {{From, Ref}, _} = queue:get(Q),
      From ! {Ref, Message}.
  
  notify_async(#state{async = Pid}, Msg) ->
      case is_pid(Pid) of
  
negative.code:                 statement,
                  columns,
                  rows = [],
                  results = [],
                  sync_required,
                  txstatus}).
  
  