anchor.diff:      end, Puller),
       {noreply, Puller}.
   
  +handle_info({'EXIT', Pid, Reason}, Puller) ->
  +    {noreply, Puller -- [Pid]};
  +handle_info(Info, Puller) ->
  +    io:format("unexpected message received: ~p~n", [Info]),
  +    {noreply, Puller}.
  +
   terminate(_Reason, _State) ->
       ok.
   
   delay_response(SrvPid, From) ->
  +    {Pid, _} = From,
  +    link(Pid),
       Timeout = lmq_queue:waittime(),
       receive
           {lmq, SrvPid, wake} -> ok
  
positive.code:     end,
      case lmq_queue:dequeue() of
          empty -> delay_response(SrvPid, From);
          Message -> gen_server:reply(From, Message)
      end.
  
negative.code: 
  init([]) ->
      lmq_queue:start(),
      process_flag(trap_exit, true),
      {ok, []}.
  
  handle_call({push, Data}, _From, Puller) ->
  