Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions Rx.NET/Source/src/System.Reactive/Concurrency/AsyncLock.cs
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,8 @@ namespace System.Reactive.Concurrency
/// </summary>
public sealed class AsyncLock : IDisposable
{
private bool isAcquired = false;
private bool hasFaulted = false;
private bool isAcquired;
private bool hasFaulted;
private readonly object guard = new object();
private Queue<(Action<Delegate, object> action, Delegate @delegate, object state)> queue;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ private sealed class CatchSchedulerPeriodic : ISchedulerPeriodic
private sealed class PeriodicallyScheduledWorkItem<TState> : IDisposable
{
private IDisposable _cancel;
private bool _failed = false;
private bool _failed;

private readonly Func<TState, TState> _action;
private readonly CatchSchedulerPeriodic _catchScheduler;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ public partial class LocalScheduler
/// or can continue using the current timer (because no earlier long term work was
/// added to the queue).
/// </summary>
private static WorkItem s_nextLongTermWorkItem = null;
private static WorkItem s_nextLongTermWorkItem;

/// <summary>
/// Short term work queue. Contains work that's due soon, computed at the time of
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ namespace System.Reactive

internal class ScheduledObserver<T> : ObserverBase<T>, IScheduledObserver<T>
{
private int _state = 0;
private int _state;
private const int STOPPED = 0;
private const int RUNNING = 1;
private const int PENDING = 2;
Expand Down
2 changes: 1 addition & 1 deletion Rx.NET/Source/src/System.Reactive/Linq/Observable/Merge.cs
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ public _(int maxConcurrent, IObserver<TSource> observer)
private Queue<IObservable<TSource>> _q = new Queue<IObservable<TSource>>();
private volatile bool _isStopped;
private CompositeDisposable _group = new CompositeDisposable();
private int _activeCount = 0;
private int _activeCount;

public override void OnNext(IObservable<TSource> value)
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -309,7 +309,7 @@ private sealed class ToTaskObserver<TResult> : SafeObserver<TResult>
{
private readonly CancellationToken _ct;
private readonly TaskCompletionSource<TResult> _tcs;
private readonly CancellationTokenRegistration _ctr = default;
private readonly CancellationTokenRegistration _ctr;

private bool _hasValue;
private TResult _lastValue;
Expand Down