protected override void CalculateState()

in src/DotPulsar/Internal/ProducerProcess.cs [43:79]
35 lines of code
10 McCabe index (conditional complexity)

    protected override void CalculateState()
    {
        if (_stateManager.IsFinalState())
            return;

        if (ExecutorState == ExecutorState.Faulted)
        {
            var newState = Exception! is ProducerFencedException ? ProducerState.Fenced : ProducerState.Faulted;
            var formerState = _stateManager.SetState(newState);
            if (formerState != ProducerState.Faulted && formerState != ProducerState.Fenced)
                ActionQueue.Enqueue(async _ => await _producer.ChannelFaulted(Exception!));
            return;
        }

        switch (ChannelState)
        {
            case ChannelState.ClosedByServer:
            case ChannelState.Disconnected:
                _stateManager.SetState(ProducerState.Disconnected);
                ActionQueue.Enqueue(async x =>
                {
                    await _producer.CloseChannel(x).ConfigureAwait(false);
                    await _producer.EstablishNewChannel(x).ConfigureAwait(false);
                });
                return;
            case ChannelState.Connected:
                ActionQueue.Enqueue(async x =>
                {
                    await _producer.ActivateChannel(TopicEpoch, x).ConfigureAwait(false);
                    _stateManager.SetState(ProducerState.Connected);
                });
                return;
            case ChannelState.WaitingForExclusive:
                _stateManager.SetState(ProducerState.WaitingForExclusive);
                return;
        }
    }