// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT License.
// See the LICENSE file in the project root for more information. 

using System.Collections.Generic;

namespace System.Reactive.Joins
{
    internal abstract class ActivePlan
    {
        private readonly Dictionary<IJoinObserver, IJoinObserver> _joinObservers = new();

        protected readonly Action _onCompleted;

        internal abstract void Match();

        protected ActivePlan(Action onCompleted)
        {
            _onCompleted = onCompleted;
        }

        protected void AddJoinObserver(IJoinObserver joinObserver)
        {
            if (!_joinObservers.ContainsKey(joinObserver))
            {
                _joinObservers.Add(joinObserver, joinObserver);
            }
        }

        protected void Dequeue()
        {
            foreach (var joinObserver in _joinObservers.Values)
            {
                joinObserver.Dequeue();
            }
        }
    }

    internal sealed class ActivePlan<T1> : ActivePlan
    {
        private readonly Action<T1> _onNext;
        private readonly JoinObserver<T1> _first;

        internal ActivePlan(JoinObserver<T1> first, Action<T1> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            AddJoinObserver(first);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0)
            {
                var n1 = _first.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted)
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value);
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2> : ActivePlan
    {
        private readonly Action<T1, T2> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, Action<T1, T2> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            AddJoinObserver(first);
            AddJoinObserver(second);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0)
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted)
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3> : ActivePlan
    {
        private readonly Action<T1, T2, T3> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third, Action<T1, T2, T3> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0)
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted)
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third, JoinObserver<T4> fourth, Action<T1, T2, T3, T4> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0)
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted)
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4, T5> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4, T5> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;
        private readonly JoinObserver<T5> _fifth;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third,
            JoinObserver<T4> fourth, JoinObserver<T5> fifth, Action<T1, T2, T3, T4, T5> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            _fifth = fifth;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
            AddJoinObserver(fifth);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0
             && _fifth.Queue.Count > 0)
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();
                var n5 = _fifth.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted
                    || n5.Kind == NotificationKind.OnCompleted)
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value,
                           n5.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4, T5, T6> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4, T5, T6> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;
        private readonly JoinObserver<T5> _fifth;
        private readonly JoinObserver<T6> _sixth;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third,
            JoinObserver<T4> fourth, JoinObserver<T5> fifth, JoinObserver<T6> sixth,
            Action<T1, T2, T3, T4, T5, T6> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            _fifth = fifth;
            _sixth = sixth;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
            AddJoinObserver(fifth);
            AddJoinObserver(sixth);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0
             && _fifth.Queue.Count > 0
             && _sixth.Queue.Count > 0)
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();
                var n5 = _fifth.Queue.Peek();
                var n6 = _sixth.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted
                    || n5.Kind == NotificationKind.OnCompleted
                    || n6.Kind == NotificationKind.OnCompleted)
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value,
                           n5.Value,
                           n6.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4, T5, T6, T7> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4, T5, T6, T7> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;
        private readonly JoinObserver<T5> _fifth;
        private readonly JoinObserver<T6> _sixth;
        private readonly JoinObserver<T7> _seventh;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third,
            JoinObserver<T4> fourth, JoinObserver<T5> fifth, JoinObserver<T6> sixth, JoinObserver<T7> seventh,
            Action<T1, T2, T3, T4, T5, T6, T7> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            _fifth = fifth;
            _sixth = sixth;
            _seventh = seventh;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
            AddJoinObserver(fifth);
            AddJoinObserver(sixth);
            AddJoinObserver(seventh);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0
             && _fifth.Queue.Count > 0
             && _sixth.Queue.Count > 0
             && _seventh.Queue.Count > 0)
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();
                var n5 = _fifth.Queue.Peek();
                var n6 = _sixth.Queue.Peek();
                var n7 = _seventh.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted
                    || n5.Kind == NotificationKind.OnCompleted
                    || n6.Kind == NotificationKind.OnCompleted
                    || n7.Kind == NotificationKind.OnCompleted)
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value,
                           n5.Value,
                           n6.Value,
                           n7.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4, T5, T6, T7, T8> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4, T5, T6, T7, T8> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;
        private readonly JoinObserver<T5> _fifth;
        private readonly JoinObserver<T6> _sixth;
        private readonly JoinObserver<T7> _seventh;
        private readonly JoinObserver<T8> _eighth;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third,
            JoinObserver<T4> fourth, JoinObserver<T5> fifth, JoinObserver<T6> sixth, JoinObserver<T7> seventh,
            JoinObserver<T8> eighth,
            Action<T1, T2, T3, T4, T5, T6, T7, T8> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            _fifth = fifth;
            _sixth = sixth;
            _seventh = seventh;
            _eighth = eighth;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
            AddJoinObserver(fifth);
            AddJoinObserver(sixth);
            AddJoinObserver(seventh);
            AddJoinObserver(eighth);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0
             && _fifth.Queue.Count > 0
             && _sixth.Queue.Count > 0
             && _seventh.Queue.Count > 0
             && _eighth.Queue.Count > 0)
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();
                var n5 = _fifth.Queue.Peek();
                var n6 = _sixth.Queue.Peek();
                var n7 = _seventh.Queue.Peek();
                var n8 = _eighth.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted
                    || n5.Kind == NotificationKind.OnCompleted
                    || n6.Kind == NotificationKind.OnCompleted
                    || n7.Kind == NotificationKind.OnCompleted
                    || n8.Kind == NotificationKind.OnCompleted
                    )
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value,
                           n5.Value,
                           n6.Value,
                           n7.Value,
                           n8.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4, T5, T6, T7, T8, T9> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4, T5, T6, T7, T8, T9> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;
        private readonly JoinObserver<T5> _fifth;
        private readonly JoinObserver<T6> _sixth;
        private readonly JoinObserver<T7> _seventh;
        private readonly JoinObserver<T8> _eighth;
        private readonly JoinObserver<T9> _ninth;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third,
            JoinObserver<T4> fourth, JoinObserver<T5> fifth, JoinObserver<T6> sixth, JoinObserver<T7> seventh,
            JoinObserver<T8> eighth, JoinObserver<T9> ninth,
            Action<T1, T2, T3, T4, T5, T6, T7, T8, T9> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            _fifth = fifth;
            _sixth = sixth;
            _seventh = seventh;
            _eighth = eighth;
            _ninth = ninth;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
            AddJoinObserver(fifth);
            AddJoinObserver(sixth);
            AddJoinObserver(seventh);
            AddJoinObserver(eighth);
            AddJoinObserver(ninth);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0
             && _fifth.Queue.Count > 0
             && _sixth.Queue.Count > 0
             && _seventh.Queue.Count > 0
             && _eighth.Queue.Count > 0
             && _ninth.Queue.Count > 0
                )
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();
                var n5 = _fifth.Queue.Peek();
                var n6 = _sixth.Queue.Peek();
                var n7 = _seventh.Queue.Peek();
                var n8 = _eighth.Queue.Peek();
                var n9 = _ninth.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted
                    || n5.Kind == NotificationKind.OnCompleted
                    || n6.Kind == NotificationKind.OnCompleted
                    || n7.Kind == NotificationKind.OnCompleted
                    || n8.Kind == NotificationKind.OnCompleted
                    || n9.Kind == NotificationKind.OnCompleted
                    )
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value,
                           n5.Value,
                           n6.Value,
                           n7.Value,
                           n8.Value,
                           n9.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;
        private readonly JoinObserver<T5> _fifth;
        private readonly JoinObserver<T6> _sixth;
        private readonly JoinObserver<T7> _seventh;
        private readonly JoinObserver<T8> _eighth;
        private readonly JoinObserver<T9> _ninth;
        private readonly JoinObserver<T10> _tenth;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third,
            JoinObserver<T4> fourth, JoinObserver<T5> fifth, JoinObserver<T6> sixth, JoinObserver<T7> seventh,
            JoinObserver<T8> eighth, JoinObserver<T9> ninth, JoinObserver<T10> tenth,
            Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            _fifth = fifth;
            _sixth = sixth;
            _seventh = seventh;
            _eighth = eighth;
            _ninth = ninth;
            _tenth = tenth;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
            AddJoinObserver(fifth);
            AddJoinObserver(sixth);
            AddJoinObserver(seventh);
            AddJoinObserver(eighth);
            AddJoinObserver(ninth);
            AddJoinObserver(tenth);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0
             && _fifth.Queue.Count > 0
             && _sixth.Queue.Count > 0
             && _seventh.Queue.Count > 0
             && _eighth.Queue.Count > 0
             && _ninth.Queue.Count > 0
             && _tenth.Queue.Count > 0
                )
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();
                var n5 = _fifth.Queue.Peek();
                var n6 = _sixth.Queue.Peek();
                var n7 = _seventh.Queue.Peek();
                var n8 = _eighth.Queue.Peek();
                var n9 = _ninth.Queue.Peek();
                var n10 = _tenth.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted
                    || n5.Kind == NotificationKind.OnCompleted
                    || n6.Kind == NotificationKind.OnCompleted
                    || n7.Kind == NotificationKind.OnCompleted
                    || n8.Kind == NotificationKind.OnCompleted
                    || n9.Kind == NotificationKind.OnCompleted
                    || n10.Kind == NotificationKind.OnCompleted
                    )
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value,
                           n5.Value,
                           n6.Value,
                           n7.Value,
                           n8.Value,
                           n9.Value,
                           n10.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;
        private readonly JoinObserver<T5> _fifth;
        private readonly JoinObserver<T6> _sixth;
        private readonly JoinObserver<T7> _seventh;
        private readonly JoinObserver<T8> _eighth;
        private readonly JoinObserver<T9> _ninth;
        private readonly JoinObserver<T10> _tenth;
        private readonly JoinObserver<T11> _eleventh;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third,
            JoinObserver<T4> fourth, JoinObserver<T5> fifth, JoinObserver<T6> sixth, JoinObserver<T7> seventh,
            JoinObserver<T8> eighth, JoinObserver<T9> ninth, JoinObserver<T10> tenth, JoinObserver<T11> eleventh,
            Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            _fifth = fifth;
            _sixth = sixth;
            _seventh = seventh;
            _eighth = eighth;
            _ninth = ninth;
            _tenth = tenth;
            _eleventh = eleventh;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
            AddJoinObserver(fifth);
            AddJoinObserver(sixth);
            AddJoinObserver(seventh);
            AddJoinObserver(eighth);
            AddJoinObserver(ninth);
            AddJoinObserver(tenth);
            AddJoinObserver(eleventh);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0
             && _fifth.Queue.Count > 0
             && _sixth.Queue.Count > 0
             && _seventh.Queue.Count > 0
             && _eighth.Queue.Count > 0
             && _ninth.Queue.Count > 0
             && _tenth.Queue.Count > 0
             && _eleventh.Queue.Count > 0
                )
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();
                var n5 = _fifth.Queue.Peek();
                var n6 = _sixth.Queue.Peek();
                var n7 = _seventh.Queue.Peek();
                var n8 = _eighth.Queue.Peek();
                var n9 = _ninth.Queue.Peek();
                var n10 = _tenth.Queue.Peek();
                var n11 = _eleventh.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted
                    || n5.Kind == NotificationKind.OnCompleted
                    || n6.Kind == NotificationKind.OnCompleted
                    || n7.Kind == NotificationKind.OnCompleted
                    || n8.Kind == NotificationKind.OnCompleted
                    || n9.Kind == NotificationKind.OnCompleted
                    || n10.Kind == NotificationKind.OnCompleted
                    || n11.Kind == NotificationKind.OnCompleted
                    )
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value,
                           n5.Value,
                           n6.Value,
                           n7.Value,
                           n8.Value,
                           n9.Value,
                           n10.Value,
                           n11.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;
        private readonly JoinObserver<T5> _fifth;
        private readonly JoinObserver<T6> _sixth;
        private readonly JoinObserver<T7> _seventh;
        private readonly JoinObserver<T8> _eighth;
        private readonly JoinObserver<T9> _ninth;
        private readonly JoinObserver<T10> _tenth;
        private readonly JoinObserver<T11> _eleventh;
        private readonly JoinObserver<T12> _twelfth;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third,
            JoinObserver<T4> fourth, JoinObserver<T5> fifth, JoinObserver<T6> sixth, JoinObserver<T7> seventh,
            JoinObserver<T8> eighth, JoinObserver<T9> ninth, JoinObserver<T10> tenth, JoinObserver<T11> eleventh,
            JoinObserver<T12> twelfth,
            Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            _fifth = fifth;
            _sixth = sixth;
            _seventh = seventh;
            _eighth = eighth;
            _ninth = ninth;
            _tenth = tenth;
            _eleventh = eleventh;
            _twelfth = twelfth;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
            AddJoinObserver(fifth);
            AddJoinObserver(sixth);
            AddJoinObserver(seventh);
            AddJoinObserver(eighth);
            AddJoinObserver(ninth);
            AddJoinObserver(tenth);
            AddJoinObserver(eleventh);
            AddJoinObserver(twelfth);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0
             && _fifth.Queue.Count > 0
             && _sixth.Queue.Count > 0
             && _seventh.Queue.Count > 0
             && _eighth.Queue.Count > 0
             && _ninth.Queue.Count > 0
             && _tenth.Queue.Count > 0
             && _eleventh.Queue.Count > 0
             && _twelfth.Queue.Count > 0
                )
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();
                var n5 = _fifth.Queue.Peek();
                var n6 = _sixth.Queue.Peek();
                var n7 = _seventh.Queue.Peek();
                var n8 = _eighth.Queue.Peek();
                var n9 = _ninth.Queue.Peek();
                var n10 = _tenth.Queue.Peek();
                var n11 = _eleventh.Queue.Peek();
                var n12 = _twelfth.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted
                    || n5.Kind == NotificationKind.OnCompleted
                    || n6.Kind == NotificationKind.OnCompleted
                    || n7.Kind == NotificationKind.OnCompleted
                    || n8.Kind == NotificationKind.OnCompleted
                    || n9.Kind == NotificationKind.OnCompleted
                    || n10.Kind == NotificationKind.OnCompleted
                    || n11.Kind == NotificationKind.OnCompleted
                    || n12.Kind == NotificationKind.OnCompleted
                    )
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value,
                           n5.Value,
                           n6.Value,
                           n7.Value,
                           n8.Value,
                           n9.Value,
                           n10.Value,
                           n11.Value,
                           n12.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;
        private readonly JoinObserver<T5> _fifth;
        private readonly JoinObserver<T6> _sixth;
        private readonly JoinObserver<T7> _seventh;
        private readonly JoinObserver<T8> _eighth;
        private readonly JoinObserver<T9> _ninth;
        private readonly JoinObserver<T10> _tenth;
        private readonly JoinObserver<T11> _eleventh;
        private readonly JoinObserver<T12> _twelfth;
        private readonly JoinObserver<T13> _thirteenth;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third,
            JoinObserver<T4> fourth, JoinObserver<T5> fifth, JoinObserver<T6> sixth, JoinObserver<T7> seventh,
            JoinObserver<T8> eighth, JoinObserver<T9> ninth, JoinObserver<T10> tenth, JoinObserver<T11> eleventh,
            JoinObserver<T12> twelfth, JoinObserver<T13> thirteenth,
            Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            _fifth = fifth;
            _sixth = sixth;
            _seventh = seventh;
            _eighth = eighth;
            _ninth = ninth;
            _tenth = tenth;
            _eleventh = eleventh;
            _twelfth = twelfth;
            _thirteenth = thirteenth;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
            AddJoinObserver(fifth);
            AddJoinObserver(sixth);
            AddJoinObserver(seventh);
            AddJoinObserver(eighth);
            AddJoinObserver(ninth);
            AddJoinObserver(tenth);
            AddJoinObserver(eleventh);
            AddJoinObserver(twelfth);
            AddJoinObserver(thirteenth);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0
             && _fifth.Queue.Count > 0
             && _sixth.Queue.Count > 0
             && _seventh.Queue.Count > 0
             && _eighth.Queue.Count > 0
             && _ninth.Queue.Count > 0
             && _tenth.Queue.Count > 0
             && _eleventh.Queue.Count > 0
             && _twelfth.Queue.Count > 0
             && _thirteenth.Queue.Count > 0
                )
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();
                var n5 = _fifth.Queue.Peek();
                var n6 = _sixth.Queue.Peek();
                var n7 = _seventh.Queue.Peek();
                var n8 = _eighth.Queue.Peek();
                var n9 = _ninth.Queue.Peek();
                var n10 = _tenth.Queue.Peek();
                var n11 = _eleventh.Queue.Peek();
                var n12 = _twelfth.Queue.Peek();
                var n13 = _thirteenth.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted
                    || n5.Kind == NotificationKind.OnCompleted
                    || n6.Kind == NotificationKind.OnCompleted
                    || n7.Kind == NotificationKind.OnCompleted
                    || n8.Kind == NotificationKind.OnCompleted
                    || n9.Kind == NotificationKind.OnCompleted
                    || n10.Kind == NotificationKind.OnCompleted
                    || n11.Kind == NotificationKind.OnCompleted
                    || n12.Kind == NotificationKind.OnCompleted
                    || n13.Kind == NotificationKind.OnCompleted
                    )
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value,
                           n5.Value,
                           n6.Value,
                           n7.Value,
                           n8.Value,
                           n9.Value,
                           n10.Value,
                           n11.Value,
                           n12.Value,
                           n13.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;
        private readonly JoinObserver<T5> _fifth;
        private readonly JoinObserver<T6> _sixth;
        private readonly JoinObserver<T7> _seventh;
        private readonly JoinObserver<T8> _eighth;
        private readonly JoinObserver<T9> _ninth;
        private readonly JoinObserver<T10> _tenth;
        private readonly JoinObserver<T11> _eleventh;
        private readonly JoinObserver<T12> _twelfth;
        private readonly JoinObserver<T13> _thirteenth;
        private readonly JoinObserver<T14> _fourteenth;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third,
            JoinObserver<T4> fourth, JoinObserver<T5> fifth, JoinObserver<T6> sixth, JoinObserver<T7> seventh,
            JoinObserver<T8> eighth, JoinObserver<T9> ninth, JoinObserver<T10> tenth, JoinObserver<T11> eleventh,
            JoinObserver<T12> twelfth, JoinObserver<T13> thirteenth, JoinObserver<T14> fourteenth,
            Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            _fifth = fifth;
            _sixth = sixth;
            _seventh = seventh;
            _eighth = eighth;
            _ninth = ninth;
            _tenth = tenth;
            _eleventh = eleventh;
            _twelfth = twelfth;
            _thirteenth = thirteenth;
            _fourteenth = fourteenth;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
            AddJoinObserver(fifth);
            AddJoinObserver(sixth);
            AddJoinObserver(seventh);
            AddJoinObserver(eighth);
            AddJoinObserver(ninth);
            AddJoinObserver(tenth);
            AddJoinObserver(eleventh);
            AddJoinObserver(twelfth);
            AddJoinObserver(thirteenth);
            AddJoinObserver(fourteenth);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0
             && _fifth.Queue.Count > 0
             && _sixth.Queue.Count > 0
             && _seventh.Queue.Count > 0
             && _eighth.Queue.Count > 0
             && _ninth.Queue.Count > 0
             && _tenth.Queue.Count > 0
             && _eleventh.Queue.Count > 0
             && _twelfth.Queue.Count > 0
             && _thirteenth.Queue.Count > 0
             && _fourteenth.Queue.Count > 0
                )
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();
                var n5 = _fifth.Queue.Peek();
                var n6 = _sixth.Queue.Peek();
                var n7 = _seventh.Queue.Peek();
                var n8 = _eighth.Queue.Peek();
                var n9 = _ninth.Queue.Peek();
                var n10 = _tenth.Queue.Peek();
                var n11 = _eleventh.Queue.Peek();
                var n12 = _twelfth.Queue.Peek();
                var n13 = _thirteenth.Queue.Peek();
                var n14 = _fourteenth.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted
                    || n5.Kind == NotificationKind.OnCompleted
                    || n6.Kind == NotificationKind.OnCompleted
                    || n7.Kind == NotificationKind.OnCompleted
                    || n8.Kind == NotificationKind.OnCompleted
                    || n9.Kind == NotificationKind.OnCompleted
                    || n10.Kind == NotificationKind.OnCompleted
                    || n11.Kind == NotificationKind.OnCompleted
                    || n12.Kind == NotificationKind.OnCompleted
                    || n13.Kind == NotificationKind.OnCompleted
                    || n14.Kind == NotificationKind.OnCompleted
                    )
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value,
                           n5.Value,
                           n6.Value,
                           n7.Value,
                           n8.Value,
                           n9.Value,
                           n10.Value,
                           n11.Value,
                           n12.Value,
                           n13.Value,
                           n14.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;
        private readonly JoinObserver<T5> _fifth;
        private readonly JoinObserver<T6> _sixth;
        private readonly JoinObserver<T7> _seventh;
        private readonly JoinObserver<T8> _eighth;
        private readonly JoinObserver<T9> _ninth;
        private readonly JoinObserver<T10> _tenth;
        private readonly JoinObserver<T11> _eleventh;
        private readonly JoinObserver<T12> _twelfth;
        private readonly JoinObserver<T13> _thirteenth;
        private readonly JoinObserver<T14> _fourteenth;
        private readonly JoinObserver<T15> _fifteenth;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third,
            JoinObserver<T4> fourth, JoinObserver<T5> fifth, JoinObserver<T6> sixth, JoinObserver<T7> seventh,
            JoinObserver<T8> eighth, JoinObserver<T9> ninth, JoinObserver<T10> tenth, JoinObserver<T11> eleventh,
            JoinObserver<T12> twelfth, JoinObserver<T13> thirteenth, JoinObserver<T14> fourteenth,
            JoinObserver<T15> fifteenth,
            Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            _fifth = fifth;
            _sixth = sixth;
            _seventh = seventh;
            _eighth = eighth;
            _ninth = ninth;
            _tenth = tenth;
            _eleventh = eleventh;
            _twelfth = twelfth;
            _thirteenth = thirteenth;
            _fourteenth = fourteenth;
            _fifteenth = fifteenth;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
            AddJoinObserver(fifth);
            AddJoinObserver(sixth);
            AddJoinObserver(seventh);
            AddJoinObserver(eighth);
            AddJoinObserver(ninth);
            AddJoinObserver(tenth);
            AddJoinObserver(eleventh);
            AddJoinObserver(twelfth);
            AddJoinObserver(thirteenth);
            AddJoinObserver(fourteenth);
            AddJoinObserver(fifteenth);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0
             && _fifth.Queue.Count > 0
             && _sixth.Queue.Count > 0
             && _seventh.Queue.Count > 0
             && _eighth.Queue.Count > 0
             && _ninth.Queue.Count > 0
             && _tenth.Queue.Count > 0
             && _eleventh.Queue.Count > 0
             && _twelfth.Queue.Count > 0
             && _thirteenth.Queue.Count > 0
             && _fourteenth.Queue.Count > 0
             && _fifteenth.Queue.Count > 0
                )
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();
                var n5 = _fifth.Queue.Peek();
                var n6 = _sixth.Queue.Peek();
                var n7 = _seventh.Queue.Peek();
                var n8 = _eighth.Queue.Peek();
                var n9 = _ninth.Queue.Peek();
                var n10 = _tenth.Queue.Peek();
                var n11 = _eleventh.Queue.Peek();
                var n12 = _twelfth.Queue.Peek();
                var n13 = _thirteenth.Queue.Peek();
                var n14 = _fourteenth.Queue.Peek();
                var n15 = _fifteenth.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted
                    || n5.Kind == NotificationKind.OnCompleted
                    || n6.Kind == NotificationKind.OnCompleted
                    || n7.Kind == NotificationKind.OnCompleted
                    || n8.Kind == NotificationKind.OnCompleted
                    || n9.Kind == NotificationKind.OnCompleted
                    || n10.Kind == NotificationKind.OnCompleted
                    || n11.Kind == NotificationKind.OnCompleted
                    || n12.Kind == NotificationKind.OnCompleted
                    || n13.Kind == NotificationKind.OnCompleted
                    || n14.Kind == NotificationKind.OnCompleted
                    || n15.Kind == NotificationKind.OnCompleted
                    )
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value,
                           n5.Value,
                           n6.Value,
                           n7.Value,
                           n8.Value,
                           n9.Value,
                           n10.Value,
                           n11.Value,
                           n12.Value,
                           n13.Value,
                           n14.Value,
                           n15.Value
                           );
                }
            }
        }
    }

    internal sealed class ActivePlan<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16> : ActivePlan
    {
        private readonly Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16> _onNext;
        private readonly JoinObserver<T1> _first;
        private readonly JoinObserver<T2> _second;
        private readonly JoinObserver<T3> _third;
        private readonly JoinObserver<T4> _fourth;
        private readonly JoinObserver<T5> _fifth;
        private readonly JoinObserver<T6> _sixth;
        private readonly JoinObserver<T7> _seventh;
        private readonly JoinObserver<T8> _eighth;
        private readonly JoinObserver<T9> _ninth;
        private readonly JoinObserver<T10> _tenth;
        private readonly JoinObserver<T11> _eleventh;
        private readonly JoinObserver<T12> _twelfth;
        private readonly JoinObserver<T13> _thirteenth;
        private readonly JoinObserver<T14> _fourteenth;
        private readonly JoinObserver<T15> _fifteenth;
        private readonly JoinObserver<T16> _sixteenth;

        internal ActivePlan(JoinObserver<T1> first, JoinObserver<T2> second, JoinObserver<T3> third,
            JoinObserver<T4> fourth, JoinObserver<T5> fifth, JoinObserver<T6> sixth, JoinObserver<T7> seventh,
            JoinObserver<T8> eighth, JoinObserver<T9> ninth, JoinObserver<T10> tenth, JoinObserver<T11> eleventh,
            JoinObserver<T12> twelfth, JoinObserver<T13> thirteenth, JoinObserver<T14> fourteenth,
            JoinObserver<T15> fifteenth, JoinObserver<T16> sixteenth,
            Action<T1, T2, T3, T4, T5, T6, T7, T8, T9, T10, T11, T12, T13, T14, T15, T16> onNext, Action onCompleted) : base(onCompleted)
        {
            _onNext = onNext;
            _first = first;
            _second = second;
            _third = third;
            _fourth = fourth;
            _fifth = fifth;
            _sixth = sixth;
            _seventh = seventh;
            _eighth = eighth;
            _ninth = ninth;
            _tenth = tenth;
            _eleventh = eleventh;
            _twelfth = twelfth;
            _thirteenth = thirteenth;
            _fourteenth = fourteenth;
            _fifteenth = fifteenth;
            _sixteenth = sixteenth;
            AddJoinObserver(first);
            AddJoinObserver(second);
            AddJoinObserver(third);
            AddJoinObserver(fourth);
            AddJoinObserver(fifth);
            AddJoinObserver(sixth);
            AddJoinObserver(seventh);
            AddJoinObserver(eighth);
            AddJoinObserver(ninth);
            AddJoinObserver(tenth);
            AddJoinObserver(eleventh);
            AddJoinObserver(twelfth);
            AddJoinObserver(thirteenth);
            AddJoinObserver(fourteenth);
            AddJoinObserver(fifteenth);
            AddJoinObserver(sixteenth);
        }

        internal override void Match()
        {
            if (_first.Queue.Count > 0
             && _second.Queue.Count > 0
             && _third.Queue.Count > 0
             && _fourth.Queue.Count > 0
             && _fifth.Queue.Count > 0
             && _sixth.Queue.Count > 0
             && _seventh.Queue.Count > 0
             && _eighth.Queue.Count > 0
             && _ninth.Queue.Count > 0
             && _tenth.Queue.Count > 0
             && _eleventh.Queue.Count > 0
             && _twelfth.Queue.Count > 0
             && _thirteenth.Queue.Count > 0
             && _fourteenth.Queue.Count > 0
             && _fifteenth.Queue.Count > 0
             && _sixteenth.Queue.Count > 0
                )
            {
                var n1 = _first.Queue.Peek();
                var n2 = _second.Queue.Peek();
                var n3 = _third.Queue.Peek();
                var n4 = _fourth.Queue.Peek();
                var n5 = _fifth.Queue.Peek();
                var n6 = _sixth.Queue.Peek();
                var n7 = _seventh.Queue.Peek();
                var n8 = _eighth.Queue.Peek();
                var n9 = _ninth.Queue.Peek();
                var n10 = _tenth.Queue.Peek();
                var n11 = _eleventh.Queue.Peek();
                var n12 = _twelfth.Queue.Peek();
                var n13 = _thirteenth.Queue.Peek();
                var n14 = _fourteenth.Queue.Peek();
                var n15 = _fifteenth.Queue.Peek();
                var n16 = _sixteenth.Queue.Peek();

                if (n1.Kind == NotificationKind.OnCompleted
                    || n2.Kind == NotificationKind.OnCompleted
                    || n3.Kind == NotificationKind.OnCompleted
                    || n4.Kind == NotificationKind.OnCompleted
                    || n5.Kind == NotificationKind.OnCompleted
                    || n6.Kind == NotificationKind.OnCompleted
                    || n7.Kind == NotificationKind.OnCompleted
                    || n8.Kind == NotificationKind.OnCompleted
                    || n9.Kind == NotificationKind.OnCompleted
                    || n10.Kind == NotificationKind.OnCompleted
                    || n11.Kind == NotificationKind.OnCompleted
                    || n12.Kind == NotificationKind.OnCompleted
                    || n13.Kind == NotificationKind.OnCompleted
                    || n14.Kind == NotificationKind.OnCompleted
                    || n15.Kind == NotificationKind.OnCompleted
                    || n16.Kind == NotificationKind.OnCompleted
                    )
                {
                    _onCompleted();
                }
                else
                {
                    Dequeue();
                    _onNext(n1.Value,
                           n2.Value,
                           n3.Value,
                           n4.Value,
                           n5.Value,
                           n6.Value,
                           n7.Value,
                           n8.Value,
                           n9.Value,
                           n10.Value,
                           n11.Value,
                           n12.Value,
                           n13.Value,
                           n14.Value,
                           n15.Value,
                           n16.Value
                           );
                }
            }
        }
    }
}