anchor.diff:  init([Server, Port]) ->
       % Attempt to connect to the server
       {ok, Sock} = connect(Server, Port),
  +
  +    % Trap any exits
  +    process_flag(trap_exit, true),
   
       % Create a command queue
       Queue = queue:new(),
  
positive.code: 
  % Formats a command to be sent to bloomd
  format_cmd({check, Filter, Key}) -> [<<"c ">>, Filter, <<" ">>, Key, <<"\n">>];
  format_cmd({multi, Filter, Keys}) when Keys =:= [] ->
      KeyList = [[<<" ">>, K] || K <- Keys],
      [<<"m ">>, Filter, KeyList, <<"\n">>];
  format_cmd({set, Filter, Key}) -> [<<"s ">>, Filter, <<" ">>, Key, <<"\n">>];
  format_cmd({bulk, Filter, Keys}) when Keys =:= [] ->
      KeyList = [[<<" ">>, K] || K <- Keys],
      [<<"b ">>, Filter, KeyList, <<"\n">>];
  format_cmd({list}) -> [<<"list\n">>];
  
negative.code: 
  
  % Processes a line of boolean Yes / No results
  process_bool_line(State, Accum, <<>>) ->
      Results = lists:reverse(Accum),
      respond_to_first(State, {ok, Results});
  
  