anchor.diff:      consume(Consumer, 100),
       timeout = ping(Consumer),
   
  -    Item = produce(Producer, 11),
  +    Item = produce(Q, Producer, 11, false),
       ok = ping(Producer),
   
       ok = ping(Consumer),
  
positive.code:         ?debugMsg("Timeout stopping " ++ Name),
          timeout
      end.
  
negative.code:         timeout
      end.
  
  produce(Q, Producer, Size, Wait) ->
      Ref = make_ref(),
      ItemsCount = couch_work_queue:item_count(Q),
      Producer ! {produce, Ref, Size},
      receive
          {item, Ref, Item} when Wait ->
              ok = wait_increment(Q, ItemsCount),
              Item;
          {item, Ref, Item} ->
              Item
      after ?TIMEOUT ->
  