diff --git a/src/Adaptive.Aeron.Tests/SubscriptionTest.cs b/src/Adaptive.Aeron.Tests/SubscriptionTest.cs index e7fe3b70..0c5d5377 100644 --- a/src/Adaptive.Aeron.Tests/SubscriptionTest.cs +++ b/src/Adaptive.Aeron.Tests/SubscriptionTest.cs @@ -76,7 +76,7 @@ public void Setup() public void ShouldEnsureTheSubscriptionIsOpenWhenPolling() { Subscription.Dispose(); - Assert.True(Subscription.Closed); + Assert.True(Subscription.IsClosed); A.CallTo(() => Conductor.ReleaseSubscription(Subscription)).MustHaveHappened(); } diff --git a/src/Adaptive.Aeron/ClientConductor.cs b/src/Adaptive.Aeron/ClientConductor.cs index 1dd541a7..ffcd7d08 100644 --- a/src/Adaptive.Aeron/ClientConductor.cs +++ b/src/Adaptive.Aeron/ClientConductor.cs @@ -478,7 +478,7 @@ internal virtual void ReleaseSubscription(Subscription subscription) _clientLock.Lock(); try { - if (!subscription.Closed) + if (!subscription.IsClosed) { EnsureOpen(); EnsureNotReentrant(); diff --git a/src/Adaptive.Aeron/Subscription.cs b/src/Adaptive.Aeron/Subscription.cs index 4b2e4157..17505a2b 100644 --- a/src/Adaptive.Aeron/Subscription.cs +++ b/src/Adaptive.Aeron/Subscription.cs @@ -423,7 +423,7 @@ public void Dispose() /// Has this object been closed and should no longer be used? /// /// true if it has been closed otherwise false. - public bool Closed => _fields.isClosed; + public bool IsClosed => _fields.isClosed; ///