Skip to content

Commit d773b88

Browse files
akarnokddanielcweber
authored andcommitted
SequenceEqual() initialization cleanup (#691)
1 parent db2873b commit d773b88

File tree

1 file changed

+6
-9
lines changed

1 file changed

+6
-9
lines changed

Rx.NET/Source/src/System.Reactive/Linq/Observable/SequenceEqual.cs

Lines changed: 6 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -30,29 +30,26 @@ public Observable(IObservable<TSource> first, IObservable<TSource> second, IEqua
3030
internal sealed class _ : IdentitySink<bool>
3131
{
3232
private readonly IEqualityComparer<TSource> _comparer;
33+
private readonly object _gate;
34+
private readonly Queue<TSource> _ql;
35+
private readonly Queue<TSource> _qr;
3336

3437
public _(IEqualityComparer<TSource> comparer, IObserver<bool> observer)
3538
: base(observer)
3639
{
3740
_comparer = comparer;
41+
_gate = new object();
42+
_ql = new Queue<TSource>();
43+
_qr = new Queue<TSource>();
3844
}
3945

40-
private object _gate;
4146
private bool _donel;
4247
private bool _doner;
43-
private Queue<TSource> _ql;
44-
private Queue<TSource> _qr;
4548

4649
private IDisposable _second;
4750

4851
public void Run(Observable parent)
4952
{
50-
_gate = new object();
51-
_donel = false;
52-
_doner = false;
53-
_ql = new Queue<TSource>();
54-
_qr = new Queue<TSource>();
55-
5653
SetUpstream(parent._first.SubscribeSafe(new FirstObserver(this)));
5754
Disposable.SetSingle(ref _second, parent._second.SubscribeSafe(new SecondObserver(this)));
5855
}

0 commit comments

Comments
 (0)