anchor.diff:                      {throttled, Rest};
                   _ ->
                       process_bytes(SessionPid, Rest, <<>>)
  -            end;
  -        error ->
  -            error
  +            end
       end.
  
positive.code: websocket_handle({binary, Bytes}, Req, State) ->
      #st{session=SessionPid,
          parser_state=ParserState,
          cpulevel=CpuLevel,
          bytes_recv={TS, V}} = State,
      case process_bytes(SessionPid, Bytes, ParserState) of
          {ok, NewParserState} ->
              {M, S, _} = TS,
              NrOfBytes = byte_size(Bytes),
              BytesRecvLastSecond = V + NrOfBytes,
              {NewCpuLevel, NewBytesRecv} =
              case os:timestamp() of
                  {M, S, _} = NewTS ->
                      {CpuLevel, {NewTS, BytesRecvLastSecond}};
                  NewTS ->
                      _ = vmq_exo:incr_bytes_received(BytesRecvLastSecond),
                      {vmq_sysmon:cpu_load_level(), {NewTS, 0}}
              end,
              {ok, Req, maybe_throttle(State#st{parser_state=NewParserState,
                                                bytes_recv=NewBytesRecv,
                                                cpulevel=NewCpuLevel})};
          {throttled, HoldBackBuf} ->
              timer:sleep(1000),
              websocket_handle({binary, HoldBackBuf}, Req,
  
negative.code: websocket_info(_Info, Req, State) ->
      {ok, Req, State}.
  
  send(TransportPid, Bin) when is_binary(Bin) ->
      TransportPid ! {send, Bin},
      ok;
  