public MessageDispatch Dequeue()

in src/Util/FifoMessageDispatchChannel.cs [158:175]

• 15 lines of code
• 8 McCabe index (conditional complexity)

        public MessageDispatch Dequeue(TimeSpan timeout)
        {
            lock(this.mutex)
            {
                // Wait until the channel is ready to deliver messages.
                if( timeout != TimeSpan.Zero && !Closed && ( Empty || !Running ) )
                {
                    Monitor.Wait(this.mutex, timeout);
                }

                if( Closed || !Running || Empty )
                {
                    return null;
                }

                return DequeueNoWait();
            }
        }