anchor.diff:      ok = gen_server:call(Svr, accepted),
       % Accept the first message and identify the datagram type.
       {ok, Data} = gen_tcp:recv(Sock, 0),
  +    self() ! {tcp, Sock, Data},
       case binary_part(Data, 0, 5) of
  -        <<"tweet">> -> tweet_loop(Sock, Data, SysTbl);
  +        <<"tweet">> -> 
  +            tweet_loop(Sock, <<>>, SysTbl);
           _ ->
  -            self() ! {tcp, Sock, Data},
               read_send_loop(Sock, SysTbl)
       end.
   
  
positive.code:                     lists:map(Fun, Msgs),
                      % The incomplete tweet at the end will be attached to the 
                      % next tweet-datagram.
                      tweet_loop(Sock, Rest, SysTbl)
              end;
          {tcp_closed, Sock} -> ok
  
negative.code:             {ok, Pid} = meeqo_pipe:start([SysTbl, Addr]),
              ets:insert(PipeRack, {Addr, Pid}),
              Pid;
          [{Addr, OldPid}] ->
              case is_process_alive(OldPid) of
                  true -> OldPid;
                  false ->
                      {ok, Pid} = meeqo_pipe:start([SysTbl, Addr]),
                      ets:insert(PipeRack, {Addr, Pid}),
  