Synchronize<TSource>
using System.Runtime.CompilerServices;
namespace System.Reactive.Concurrency
{
[System.Runtime.CompilerServices.NullableContext(1)]
[System.Runtime.CompilerServices.Nullable(new byte[] {
0,
1,
1,
1
})]
internal sealed class Synchronize<[System.Runtime.CompilerServices.Nullable(2)] TSource> : Producer<TSource, Synchronize<TSource>._>
{
[System.Runtime.CompilerServices.Nullable(new byte[] {
0,
1
})]
internal sealed class _ : IdentitySink<TSource>
{
private readonly object _gate;
public _(Synchronize<TSource> parent, IObserver<TSource> observer)
: base(observer)
{
_gate = (parent._gate ?? new object());
}
public override void OnNext(TSource value)
{
lock (_gate) {
ForwardOnNext(value);
}
}
public override void OnError(Exception error)
{
lock (_gate) {
ForwardOnError(error);
}
}
public override void OnCompleted()
{
lock (_gate) {
ForwardOnCompleted();
}
}
}
private readonly IObservable<TSource> _source;
[System.Runtime.CompilerServices.Nullable(2)]
private readonly object _gate;
public Synchronize(IObservable<TSource> source, object gate)
{
_source = source;
_gate = gate;
}
public Synchronize(IObservable<TSource> source)
{
_source = source;
}
[return: System.Runtime.CompilerServices.Nullable(new byte[] {
1,
0
})]
protected override _ CreateSink(IObserver<TSource> observer)
{
return new _(this, observer);
}
protected override void Run([System.Runtime.CompilerServices.Nullable(new byte[] {
1,
0
})] _ sink)
{
sink.Run(_source);
}
}
}