40 lines
819 B
C#
40 lines
819 B
C#
using System;
|
|
|
|
namespace UniRx.Operators
|
|
{
|
|
internal class SynchronizedObserver<T> : IObserver<T>
|
|
{
|
|
private readonly object gate;
|
|
private readonly IObserver<T> observer;
|
|
|
|
public SynchronizedObserver(IObserver<T> observer, object gate)
|
|
{
|
|
this.observer = observer;
|
|
this.gate = gate;
|
|
}
|
|
|
|
public void OnNext(T value)
|
|
{
|
|
lock (gate)
|
|
{
|
|
observer.OnNext(value);
|
|
}
|
|
}
|
|
|
|
public void OnError(Exception error)
|
|
{
|
|
lock (gate)
|
|
{
|
|
observer.OnError(error);
|
|
}
|
|
}
|
|
|
|
public void OnCompleted()
|
|
{
|
|
lock (gate)
|
|
{
|
|
observer.OnCompleted();
|
|
}
|
|
}
|
|
}
|
|
} |