anchor.diff:  % second handle a msg when there's no messages in buffer
   handle_cast({send, Msg, StartTime}, {Info, OldState=#state{messages={_,[]}}}) ->
       State = OldState#state{messages={StartTime, [Msg]}, buffer_size=byte_size(Msg)+22},
  +    {noreply, {Info, State}};
  +
  +% third handle if the msg is big enough to promotes the current msgs buffer to a packet
  +handle_cast({send, Msg, Start}, {Info, OldState=#state{packets=Pckts, messages=Msgs, buffer_size=Size}})
  +        when Size+byte_size(Msg)+2 > ?PACKET_SIZE ->
  +    State = OldState#state{packets=[Msgs|Pckts], messages={Start, [Msg]}, buffer_size=0},
       case flush(Info, State) of
           {ok, NewState} ->
               {noreply, {Info, NewState}};
  
positive.code:             molderl_recovery:store(Info#info.recovery_service, EncodedMsgs, EncodedMsgsSize, NumMsgs),
              statsderl:timing_now(Info#info.statsd_latency_key_out, Start, 0.1),
              statsderl:increment(Info#info.statsd_count_key, 1, 0.1),
              flush(Info, SeqNum+NumMsgs, Pckts);
          {error, eagain} -> % retry next cycle
              {ok, SeqNum, lists:reverse([{Start, Msgs}|Pckts])};
          {error, Reason} ->
              Log = "[molderl] Experienced issue ~p (~p) writing to UDP socket. Resetting.",
  
negative.code:     flush(Info, SeqNum, Pckts);
  
  flush(Info=#info{stream_name=Name, socket=Socket}, SeqNum, [{Start, Msgs}|Pckts]) ->
      lager:debug("[molderl] Encoding and sending mold packet. Stream:~p, SeqNum:~p, Remaining Packets:~p.~n", [Name, SeqNum, length(Pckts)]),
      {EncodedMsgs, EncodedMsgsSize, NumMsgs} = molderl_utils:encode_messages(Msgs),
      Payload = molderl_utils:gen_messagepacket(Name, SeqNum, NumMsgs, EncodedMsgs),
      case gen_udp:send(Socket, Info#info.destination, Info#info.destination_port, Payload) of
  