<PackageReference Include="System.Reactive" Version="6.0.0-preview.16" />
AverageDoubleNullable
using System.
Runtime.
CompilerServices;
namespace System.
Reactive.
Linq.
ObservableImpl
{
[
System.
Runtime.
CompilerServices.
NullableContext(
1)]
[
System.
Runtime.
CompilerServices.
Nullable(
new byte[] {
0,
1
})]
internal sealed class AverageDoubleNullable :
Producer<
double?,
AverageDoubleNullable.
_>
{
[
System.
Runtime.
CompilerServices.
NullableContext(
0)]
internal sealed class _ :
IdentitySink<
double?>
{
private double _sum;
private long _count;
[
System.
Runtime.
CompilerServices.
NullableContext(
1)]
public _(
IObserver<
double?>
observer)
:
base(
observer)
{
_sum =
0;
_count =
0;
}
public override void OnNext(
double?
value)
{
try {
if (
value.
HasValue) {
_sum +=
value.
Value;
checked {
_count++;
}
}
}
catch (
Exception error) {
ForwardOnError(
error);
}
}
public override void OnCompleted()
{
if (
_count >
0)
ForwardOnNext(
_sum / (
double)
_count);
else
ForwardOnNext(
null);
ForwardOnCompleted();
}
}
private readonly IObservable<
double?>
_source;
public AverageDoubleNullable(
IObservable<
double?>
source)
{
_source =
source;
}
protected override _ CreateSink(
IObserver<
double?>
observer)
{
return new _(
observer);
}
protected override void Run(
_ sink)
{
sink.
Run(
_source);
}
}
}