LongCount<TSource>
using System.Runtime.CompilerServices;
namespace System.Reactive.Linq.ObservableImpl
{
[System.Runtime.CompilerServices.NullableContext(1)]
[System.Runtime.CompilerServices.Nullable(0)]
internal static class LongCount<[System.Runtime.CompilerServices.Nullable(2)] TSource>
{
[System.Runtime.CompilerServices.Nullable(new byte[] {
0,
1,
0
})]
internal sealed class All : Producer<long, All._>
{
[System.Runtime.CompilerServices.Nullable(new byte[] {
0,
1
})]
internal sealed class _ : Sink<TSource, long>
{
private long _count;
public _(IObserver<long> observer)
: base(observer)
{
}
public override void OnNext(TSource value)
{
checked {
try {
_count++;
} catch (Exception error) {
ForwardOnError(error);
}
}
}
public override void OnCompleted()
{
ForwardOnNext(_count);
ForwardOnCompleted();
}
}
private readonly IObservable<TSource> _source;
public All(IObservable<TSource> source)
{
_source = source;
}
[return: System.Runtime.CompilerServices.Nullable(new byte[] {
1,
0
})]
protected override _ CreateSink(IObserver<long> observer)
{
return new _(observer);
}
protected override void Run([System.Runtime.CompilerServices.Nullable(new byte[] {
1,
0
})] _ sink)
{
sink.Run(_source);
}
}
[System.Runtime.CompilerServices.Nullable(new byte[] {
0,
1,
0
})]
internal sealed class Predicate : Producer<long, Predicate._>
{
[System.Runtime.CompilerServices.Nullable(new byte[] {
0,
1
})]
internal sealed class _ : Sink<TSource, long>
{
private readonly Func<TSource, bool> _predicate;
private long _count;
public _(Func<TSource, bool> predicate, IObserver<long> observer)
: base(observer)
{
_predicate = predicate;
}
public override void OnNext(TSource value)
{
checked {
try {
if (_predicate(value))
_count++;
} catch (Exception error) {
ForwardOnError(error);
}
}
}
public override void OnCompleted()
{
ForwardOnNext(_count);
ForwardOnCompleted();
}
}
private readonly IObservable<TSource> _source;
private readonly Func<TSource, bool> _predicate;
public Predicate(IObservable<TSource> source, Func<TSource, bool> predicate)
{
_source = source;
_predicate = predicate;
}
[return: System.Runtime.CompilerServices.Nullable(new byte[] {
1,
0
})]
protected override _ CreateSink(IObserver<long> observer)
{
return new _(_predicate, observer);
}
protected override void Run([System.Runtime.CompilerServices.Nullable(new byte[] {
1,
0
})] _ sink)
{
sink.Run(_source);
}
}
}
}