Reactive.Backpressure/ExtensionMethods.cs
/// <summary>
/// Starts next observable if possible or needed.
/// </summary>
Starts next observable if possible or needed.
Starts next observable if possible or needed .
private void StartNext()
            {
                var values = buffer.ToArray();
                buffer.Clear();
                if (values.Length == 0)
                    return;
                if (!subject.HasObservers)
                    return;
                var currentObservable = selector(values);
                currentSubscription = currentObservable.Subscribe(OnNextSelected, OnErrorSelected, OnCompletedSelected);
            }
private void StartNext ( ) { var values = buffer . ToArray ( ) ; buffer . Clear ( ) ; if ( values . Length == 0 ) return ; if ( ! subject . HasObservers ) return ; var currentObservable = selector ( values ) ; currentSubscription = currentObservable . Subscribe ( OnNextSelected , OnErrorSelected , OnCompletedSelected ) ; }
Starts next observable if possible or needed.
Starts next observable if possible or needed .