public async Task AwaitSettingNegotiationCompletion()

in rocketmq-client-csharp/Session.cs [104:113]

• 9 lines of code
• 2 McCabe index (conditional complexity)

        public async Task AwaitSettingNegotiationCompletion()
        {
            if (0 != Interlocked.Read(ref _established))
            {
                return;
            }

            Logger.Debug("Await setting negotiation");
            await _channel.Reader.ReadAsync();
        }