anchor.diff:          Msg when is_pid(SendToPidOrKeep) ->
               SendToPidOrKeep ! {WaitFor, Msg},
               wait_msg_loop(SendToPidOrKeep, WaitFor, Acc);
  -        Msg when SendToPidOrKeep =:= 'keep' ->
  +        {WaitFor, Msg} when SendToPidOrKeep =:= 'keep' ->
               wait_msg_loop(SendToPidOrKeep, WaitFor, [Msg | Acc])
       end.
   
  
positive.code: -compile(export_all).
  
  -include_lib("eunit/include/eunit.hrl").
  
  -spec batch_receiver_and_loop(Topic) -> PidOfKeeper when
      Topic           :: erlroute:topic(),
  
negative.code: 
  -spec read_from_receiver(KeeperPid) -> Result when
      KeeperPid       :: pid(),
      Result          :: [] | [term()] | timeout_in_receiver.
  
  read_from_receiver(KeeperPid) ->
      KeeperPid ! {'read_and_die', self()},
      receive
          Data -> Data
          after 15 -> timeout_in_receiver
      end.
  
  % batch receive loop in separate process (awaiting message in topic)
  batch_loop(Topic) ->
  