anchor.diff:      %% initialize gauge for spawned cast workers
       undefined = put(?async_workers, 0),
       %% initialize internal counters
  +    undefined = put(?request_input, 0),
  +    undefined = put(?cast_input, 0),
       undefined = put(?max_processes_reached, 0),
       undefined = put(?max_messages_reached, 0),
  +    undefined = put(?suspend_sent, 0),
       {ok,
        #state{socket = Socket,
               ready = false, %% will wait for 'ready' signal
  
positive.code:                    State#state.socket,
                     ?PACKET_FLOW_CONTROL_SUSPEND(Millis)) of
                  ok ->
                      ok;
                  {error, _Reason} ->
                      stop
              end
  
negative.code: %% gauge for spawned workers for cast requests
  -define(async_workers, async_workers).
  
  %% internal counters
  -define(request_input, request_input).
  -define(cast_input, cast_input).
  -define(max_processes_reached, max_processes_reached).
  -define(max_messages_reached, max_messages_reached).
  -define(suspend_sent, suspend_sent).
  
  %% ----------------------------------------------------------------------
  %% Erlang interface definitions
  