anchor.diff:                              ok, Message),
                   %% may fail, when tcp just closed
                   _ = inet:setopts(Socket, [{active, once}]),
  -                inc_r_msg_count(State);
  +                state_after_receiving(State, lists:nth(1, Message));
               {?deliver, Process, Message} ->
                   ?TRACE("Received message ~.0p", [Message]),
                   ?LOG_MESSAGE_SOCK('rcv', Data, byte_size(Data), channel(State)),
                   forward_msg(Process, Message, State),
                   %% may fail, when tcp just closed
                   _ = inet:setopts(Socket, [{active, once}]),
  -                inc_r_msg_count(State);
  +                state_after_receiving(State, Message);
               {user_close} ->
                   log:log(warn,"[ CC ~p (~p) ] tcp user_close request", [self(), pid_groups:my_pidname()]),
                   close_connection(Socket, State);
  
positive.code: 
  on({web_debug_info, Requestor}, State) ->
      Now = os:timestamp(),
      LastMsgSent = last_msg_sent(State),
      SecondsAgo =
          case LastMsgSent of
              {0,0,0} -> infinity;
              _ ->  timer:now_diff(Now, last_msg_sent(State)) div 1000000
          end,
      Runtime = timer:now_diff(Now, started(State)) / 1000000,
      {SentPerS, ReceivedPerS} =
  
negative.code:                    % -> to process this 1 msg + MQL messages (see below)
                     set_desired_bundle_size(T2, erlang:min(MQL, MaxBundle));
                 true ->
                     send(DestPid, Message, Options, State)
              end;
          QL ->
              {MsgQueue0, OptionQueue0} = msg_queue(State),
  