anchor.diff:  
   -module(couch_work_queue).
   -behaviour(gen_server).
  +
  +-include("couch_db.hrl").
   
   % public API
   -export([new/1, queue/2, dequeue/1, dequeue/2, close/1]).
  
positive.code:         {reply, ok, Q}
      end;
  
  handle_call({queue, Item}, _From, #q{work_waiters = [{W, _Max} | Rest]} = Q) ->
      gen_server:reply(W, {ok, [Item]}),
      {reply, ok, Q#q{work_waiters = Rest}};
  
  
negative.code:     gen_server:start_link(couch_work_queue, Options, []).
  
  
  queue(Wq, Item) when is_binary(Item) ->
      gen_server:call(Wq, {queue, Item, byte_size(Item)}, infinity);
  queue(Wq, Item) ->
      gen_server:call(Wq, {queue, Item, byte_size(?term_to_bin(Item))}, infinity).
  
  
  dequeue(Wq) ->
  