You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by bl...@apache.org on 2022/12/06 13:44:38 UTC
[pulsar-dotpulsar] branch master updated: Make ready for release 2.6.0
This is an automated email from the ASF dual-hosted git repository.
blankensteiner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-dotpulsar.git
The following commit(s) were added to refs/heads/master by this push:
new b4e74cf Make ready for release 2.6.0
b4e74cf is described below
commit b4e74cf356e9a33efd85b7945975b2dede15382d
Author: Daniel Blankensteiner <db...@vmail.dk>
AuthorDate: Tue Dec 6 14:44:27 2022 +0100
Make ready for release 2.6.0
---
CHANGELOG.md | 2 +-
src/DotPulsar/DotPulsar.csproj | 2 +-
src/DotPulsar/Extensions/StateExtensions.cs | 10 +++-------
3 files changed, 5 insertions(+), 9 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index e0e906a..cfda092 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -4,7 +4,7 @@ All notable changes to this project will be documented in this file.
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/) and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
-## [Unreleased]
+## [2.6.0] - 2022-12-06
### Added
diff --git a/src/DotPulsar/DotPulsar.csproj b/src/DotPulsar/DotPulsar.csproj
index c7e3038..bfb01b1 100644
--- a/src/DotPulsar/DotPulsar.csproj
+++ b/src/DotPulsar/DotPulsar.csproj
@@ -2,7 +2,7 @@
<PropertyGroup>
<TargetFrameworks>netstandard2.0;netstandard2.1;net6.0;net7.0</TargetFrameworks>
- <Version>2.5.2</Version>
+ <Version>2.6.0</Version>
<AssemblyVersion>$(Version)</AssemblyVersion>
<FileVersion>$(Version)</FileVersion>
<Authors>ApachePulsar,DanskeCommodities,dblank</Authors>
diff --git a/src/DotPulsar/Extensions/StateExtensions.cs b/src/DotPulsar/Extensions/StateExtensions.cs
index 89dc2ef..90f0364 100644
--- a/src/DotPulsar/Extensions/StateExtensions.cs
+++ b/src/DotPulsar/Extensions/StateExtensions.cs
@@ -110,9 +110,6 @@ public static class StateExtensions
/// <returns>
/// ValueTask that will run as long as a final state is not entered.
/// </returns>
- /// <remarks>
- /// If the state change to a final state, then the returned task will complete.
- /// </remarks>
public static async ValueTask DelayedStateMonitor<TEntity, TState>(
this TEntity stateImplementer,
TState state,
@@ -121,8 +118,10 @@ public static class StateExtensions
Func<TEntity, TState, CancellationToken, ValueTask> onStateReached,
CancellationToken cancellationToken) where TEntity : IState<TState> where TState : notnull
{
- while (!cancellationToken.IsCancellationRequested)
+ while (true)
{
+ cancellationToken.ThrowIfCancellationRequested();
+
var currentState = await stateImplementer.OnStateChangeFrom(state, delay, cancellationToken).ConfigureAwait(false);
if (stateImplementer.IsFinalState(currentState))
return;
@@ -157,9 +156,6 @@ public static class StateExtensions
/// <returns>
/// ValueTask that will run as long as a final state is not entered.
/// </returns>
- /// <remarks>
- /// If the state change to a final state, then the returned task will complete.
- /// </remarks>
public static async ValueTask DelayedStateMonitor<TEntity, TState>(
this TEntity stateImplementer,
TState state,