AverageDecimalNullable
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 AverageDecimalNullable :
Producer<
decimal?,
AverageDecimalNullable.
_>
{
[
System.
Runtime.
CompilerServices.
NullableContext(
0)]
internal sealed class _ :
IdentitySink<
decimal?>
{
private decimal _sum;
private long _count;
[
System.
Runtime.
CompilerServices.
NullableContext(
1)]
public _(
IObserver<
decimal?>
observer)
:
base(
observer)
{
_sum =
default(
decimal);
_count =
0;
}
public override void OnNext(
decimal?
value)
{
checked {
try {
if (
value.
HasValue) {
_sum +=
value.
Value;
_count++;
}
}
catch (
Exception error) {
ForwardOnError(
error);
}
}
}
public override void OnCompleted()
{
if (
_count >
0)
ForwardOnNext(
_sum / (
decimal)
_count);
else
ForwardOnNext(
null);
ForwardOnCompleted();
}
}
private readonly IObservable<
decimal?>
_source;
public AverageDecimalNullable(
IObservable<
decimal?>
source)
{
_source =
source;
}
protected override _ CreateSink(
IObserver<
decimal?>
observer)
{
return new _(
observer);
}
protected override void Run(
_ sink)
{
sink.
Run(
_source);
}
}
}