* merged results branch with master

Telegrator.Analyzers/GlobalSuppressions.cs

@@ -0,0 +1,8 @@
+// This file is used by Code Analysis to maintain SuppressMessage
+// attributes that are applied to this project.
+// Project-level suppressions either have no target or are given
+// a specific target and scoped to a namespace, type, member, etc.
+
+using System.Diagnostics.CodeAnalysis;
+
+[assembly: SuppressMessage("Style", "IDE0090")]

Telegrator.Generators/GlobalSuppressions.cs

@@ -0,0 +1,8 @@
+// This file is used by Code Analysis to maintain SuppressMessage
+// attributes that are applied to this project.
+// Project-level suppressions either have no target or are given
+// a specific target and scoped to a namespace, type, member, etc.
+
+using System.Diagnostics.CodeAnalysis;
+
+[assembly: SuppressMessage("Style", "IDE0090")]

Telegrator.Hosting.Web/Polling/HostedUpdateWebhooker.cs

@@ -1,6 +1,5 @@
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Http;
-using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Options;
 using Microsoft.Extensions.Primitives;
@@ -22,7 +21,7 @@ namespace Telegrator.Hosting.Web.Polling
         private readonly ITelegramBotWebHost _botHost;
         private readonly ITelegramBotClient _botClient;
         private readonly IUpdateRouter _updateRouter;
-        private readonly TelegramBotWebOptions _options;
+        private readonly TelegratorWebOptions _options;
 
         /// <summary>
         /// Initiallizes new instance of <see cref="HostedUpdateWebhooker"/>
@@ -32,7 +31,7 @@ namespace Telegrator.Hosting.Web.Polling
         /// <param name="updateRouter"></param>
         /// <param name="options"></param>
         /// <exception cref="ArgumentNullException"></exception>
-        public HostedUpdateWebhooker(ITelegramBotWebHost botHost, ITelegramBotClient botClient, IUpdateRouter updateRouter, IOptions<TelegramBotWebOptions> options)
+        public HostedUpdateWebhooker(ITelegramBotWebHost botHost, ITelegramBotClient botClient, IUpdateRouter updateRouter, IOptions<TelegratorWebOptions> options)
         {
             if (string.IsNullOrEmpty(options.Value.WebhookUri))
                 throw new ArgumentNullException(nameof(options), "Option \"WebhookUrl\" must be set to subscribe for update recieving");

Telegrator.Hosting.Web/TelegramBotWebHostBuilder.cs

@@ -43,10 +43,6 @@ namespace Telegrator.Hosting.Web
             _innerBuilder = webApplicationBuilder;
             _settings = settings ?? throw new ArgumentNullException(nameof(settings));
             _handlers = new HostHandlersCollection(Services, _settings);
-
-            Services.AddSingleton<IOptions<TelegramBotWebOptions>>(Options.Create(settings));
-            Services.Configure<TelegratorOptions>(Configuration.GetSection(nameof(TelegratorOptions)));
-            Services.Configure<TelegramBotClientOptions>(Configuration.GetSection(nameof(TelegramBotClientOptions)), new TelegramBotClientOptionsProxy());
         }
 
         /// <summary>
@@ -67,6 +63,15 @@ namespace Telegrator.Hosting.Web
                 }
             }
 
+            if (!_settings.DisableAutoConfigure)
+            {
+                Services.Configure<TelegratorWebOptions>(Configuration.GetSection(nameof(TelegratorWebOptions)));
+                Services.Configure<TelegratorOptions>(Configuration.GetSection(nameof(TelegratorOptions)));
+                Services.Configure<TelegramBotClientOptions>(Configuration.GetSection(nameof(TelegramBotClientOptions)), new TelegramBotClientOptionsProxy());
+            }
+
+            Services.AddSingleton<IConfigurationManager>(Configuration);
+            Services.AddSingleton<IOptions<TelegratorOptions>>(Options.Create(_settings));
             return new TelegramBotWebHost(_innerBuilder, _handlers);
         }
     }

Telegrator.Hosting/Polling/HostUpdateHandlersPool.cs

@@ -1,6 +1,5 @@
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
-using Telegrator.MadiatorCore.Descriptors;
 using Telegrator.Polling;
 
 namespace Telegrator.Hosting.Polling
@@ -9,12 +8,5 @@ namespace Telegrator.Hosting.Polling
     public class HostUpdateHandlersPool(IOptions<TelegratorOptions> options, ILogger<HostUpdateHandlersPool> logger) : UpdateHandlersPool(options.Value, options.Value.GlobalCancellationToken)
     {
         private readonly ILogger<HostUpdateHandlersPool> _logger = logger;
-
-        /// <inheritdoc/>
-        protected override async Task ExecuteHandlerWrapper(DescribedHandlerInfo enqueuedHandler)
-        {
-            //_logger.LogInformation("Handler \"{0}\" has entered execution pool", enqueuedHandler.DisplayString);
-            await base.ExecuteHandlerWrapper(enqueuedHandler);
-        }
     }
 }

Telegrator.Hosting/TelegramBotHostBuilder.cs

@@ -77,6 +77,7 @@ namespace Telegrator.Hosting
             }
 
             Services.AddSingleton<IOptions<TelegratorOptions>>(Options.Create(_settings));
+            Services.AddSingleton<IConfigurationManager>(Configuration);
             return new TelegramBotHost(_innerBuilder, _handlers);
         }
     }

Telegrator.Tests/TestUpdateHandler.cs

@@ -13,11 +13,11 @@ namespace Telegrator.Tests
     {
         public bool WasExecuted { get; private set; }
 
-        public override Task Execute(IAbstractHandlerContainer<Message> container, CancellationToken cancellationToken)
+        public override Task<Result> Execute(IAbstractHandlerContainer<Message> container, CancellationToken cancellationToken)
         {
             cancellationToken.ThrowIfCancellationRequested();
             WasExecuted = true;
-            return Task.CompletedTask;
+            return Task.FromResult(Result.Ok());
         }
     }
 }

Telegrator.sln

@@ -20,6 +20,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Telegrator.Analyzers", "Tel
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Telegrator.Hosting.Web", "Telegrator.Hosting.Web\Telegrator.Hosting.Web.csproj", "{98AB490F-6A36-CCFF-F6E6-B029D1665965}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "SosalBot", "..\SosalBot\SosalBot\SosalBot.csproj", "{D6AA4D47-0DCE-520E-5779-A14EA9CB1DEC}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		AnalyzersDebug|Any CPU = AnalyzersDebug|Any CPU
@@ -63,6 +65,12 @@ Global
 		{98AB490F-6A36-CCFF-F6E6-B029D1665965}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{98AB490F-6A36-CCFF-F6E6-B029D1665965}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{98AB490F-6A36-CCFF-F6E6-B029D1665965}.Release|Any CPU.Build.0 = Release|Any CPU
+		{D6AA4D47-0DCE-520E-5779-A14EA9CB1DEC}.AnalyzersDebug|Any CPU.ActiveCfg = Release|Any CPU
+		{D6AA4D47-0DCE-520E-5779-A14EA9CB1DEC}.AnalyzersDebug|Any CPU.Build.0 = Release|Any CPU
+		{D6AA4D47-0DCE-520E-5779-A14EA9CB1DEC}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D6AA4D47-0DCE-520E-5779-A14EA9CB1DEC}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D6AA4D47-0DCE-520E-5779-A14EA9CB1DEC}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D6AA4D47-0DCE-520E-5779-A14EA9CB1DEC}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

Telegrator/Configuration/ITelegratorOptions.cs

@@ -6,11 +6,18 @@
     /// </summary>
     public interface ITelegratorOptions
     {
+        /*
         /// <summary>
         /// Gets or sets a value indicating whether only the first found handler should be executed for each update.
         /// </summary>
         public bool ExecuteOnlyFirstFoundHanlder { get; set; }
 
+        /// <summary>
+        /// Gets or sets a value indicating whether to descend the indexr of handler's index on register. ('false' by default)
+        /// </summary>
+        public bool DescendDescriptorIndex { get; set; }
+        */
+
         /// <summary>
         /// Gets or sets the maximum number of parallel working handlers. Null means no limit.
         /// </summary>
@@ -21,19 +28,14 @@
         /// </summary>
         public bool ExclusiveAwaitingHandlerRouting { get; set; }
 
-        /// <summary>
-        /// Gets or sets the global cancellation token for all bot operations.
-        /// </summary>
-        public CancellationToken GlobalCancellationToken { get; set; }
-
-        /// <summary>
-        /// Gets or sets a value indicating whether to descend the indexr of handler's index on register. ('false' by default)
-        /// </summary>
-        public bool DescendDescriptorIndex { get; set; }
-
         /// <summary>
         /// Gets or sets a value indicating whether to exclude intersecting command aliases.
         /// </summary>
         public bool ExceptIntersectingCommandAliases { get; set; }
+
+        /// <summary>
+        /// Gets or sets the global cancellation token for all bot operations.
+        /// </summary>
+        public CancellationToken GlobalCancellationToken { get; set; }
     }
 }

Telegrator/Handlers/Building/AwaiterHandler.cs

@@ -51,10 +51,10 @@ namespace Telegrator.Handlers.Building
         /// <param name="container">The handler container (unused).</param>
         /// <param name="cancellation">The cancellation token (unused).</param>
         /// <returns>A completed task.</returns>
-        protected override Task ExecuteInternal(IHandlerContainer container, CancellationToken cancellation)
+        protected override Task<Result> ExecuteInternal(IHandlerContainer container, CancellationToken cancellation)
         {
             ResetEvent.Set();
-            return Task.CompletedTask;
+            return Task.FromResult(Result.Ok());
         }
 
         /// <summary>

Telegrator/Handlers/Building/BuildedAbstractHandler.cs

@@ -31,7 +31,7 @@ namespace Telegrator.Handlers.Building
         /// <param name="container">The handler container with execution context.</param>
         /// <param name="cancellation">The cancellation token.</param>
         /// <returns>A task representing the asynchronous execution.</returns>
-        public override Task Execute(IAbstractHandlerContainer<TUpdate> container, CancellationToken cancellation)
+        public override Task<Result> Execute(IAbstractHandlerContainer<TUpdate> container, CancellationToken cancellation)
             => HandlerAction.Invoke(container, cancellation);
     }
 }

Telegrator/Handlers/Building/HandlerBuilder.cs

@@ -11,7 +11,7 @@ namespace Telegrator.Handlers.Building
     /// <param name="container">The handler container with execution context.</param>
     /// <param name="cancellation">The cancellation token.</param>
     /// <returns>A task representing the asynchronous execution.</returns>
-    public delegate Task AbstractHandlerAction<TUpdate>(IAbstractHandlerContainer<TUpdate> container, CancellationToken cancellation) where TUpdate : class;
+    public delegate Task<Result> AbstractHandlerAction<TUpdate>(IAbstractHandlerContainer<TUpdate> container, CancellationToken cancellation) where TUpdate : class;
 
     /// <summary>
     /// Builder class for creating regular handlers that can process updates.

Telegrator/Handlers/Components/AbstractUpdateHandler.cs

@@ -74,10 +74,10 @@ namespace Telegrator.Handlers.Components
         /// <param name="container">The handler container.</param>
         /// <param name="cancellationToken">Cancellation token.</param>
         /// <returns>A task representing the asynchronous operation.</returns>
-        protected override sealed async Task ExecuteInternal(IHandlerContainer container, CancellationToken cancellationToken)
+        protected override sealed async Task<Result> ExecuteInternal(IHandlerContainer container, CancellationToken cancellationToken)
         {
             Container = (IAbstractHandlerContainer<TUpdate>)container;
-            await Execute(Container, cancellationToken);
+            return await Execute(Container, cancellationToken);
         }
 
         /// <summary>
@@ -86,6 +86,6 @@ namespace Telegrator.Handlers.Components
         /// <param name="container">The handler container.</param>
         /// <param name="cancellation">Cancellation token.</param>
         /// <returns>A task representing the asynchronous operation.</returns>
-        public abstract Task Execute(IAbstractHandlerContainer<TUpdate> container, CancellationToken cancellation);
+        public abstract Task<Result> Execute(IAbstractHandlerContainer<TUpdate> container, CancellationToken cancellation);
     }
 }

Telegrator/Handlers/Components/BranchingUpdateHandler.cs

@@ -118,13 +118,13 @@ namespace Telegrator.Handlers.Components
         /// <param name="container">The handler container.</param>
         /// <param name="cancellation">The cancellation token.</param>
         /// <exception cref="Exception">Thrown when no branch method is set.</exception>
-        public override async Task Execute(IAbstractHandlerContainer<TUpdate> container, CancellationToken cancellation)
+        public override async Task<Result> Execute(IAbstractHandlerContainer<TUpdate> container, CancellationToken cancellation)
         {
             if (branchMethodInfo is null)
                 throw new Exception();
 
             Cancellation = cancellation;
-            await BranchExecuteWrapper(container, branchMethodInfo);
+            return await BranchExecuteWrapper(container, branchMethodInfo);
         }
 
         /// <summary>
@@ -132,21 +132,20 @@ namespace Telegrator.Handlers.Components
         /// </summary>
         /// <param name="container">The handler container.</param>
         /// <param name="methodInfo">The method to execute.</param>
-        protected virtual async Task BranchExecuteWrapper(IAbstractHandlerContainer<TUpdate> container, MethodInfo methodInfo)
+        protected virtual async Task<Result> BranchExecuteWrapper(IAbstractHandlerContainer<TUpdate> container, MethodInfo methodInfo)
         {
             if (methodInfo.ReturnType == typeof(void))
             {
                 methodInfo.Invoke(this, []);
-                return;
+                return Result.Ok();
             }
             else
             {
                 object branchReturn = methodInfo.Invoke(this, []);
-                if (branchReturn == null)
+                if (branchReturn is not Task<Result> branchTask)
-                    return;
+                    throw new InvalidOperationException();
                 
-                if (branchReturn is Task branchTask)
+                return await branchTask;
-                    await branchTask;
             }
         }
 

Telegrator/Handlers/Components/UpdateHandlerBase.cs

@@ -24,11 +24,17 @@ namespace Telegrator.Handlers.Components
         /// <param name="container">The <see cref="IHandlerContainer"/> for the update.</param>
         /// <param name="cancellationToken">The cancellation token.</param>
         /// <returns>A <see cref="Task"/> representing the asynchronous operation.</returns>
-        public async Task Execute(IHandlerContainer container, CancellationToken cancellationToken = default)
+        public async Task<Result> Execute(IHandlerContainer container, CancellationToken cancellationToken = default)
+        {
+            try
+            {
+                return await ExecuteInternal(container, cancellationToken);
+            }
+            finally
             {
-            await ExecuteInternal(container, cancellationToken);
                 LifetimeToken.LifetimeEnded();
             }
+        }
 
         /// <summary>
         /// Executes the handler logic for the given container and cancellation token.
@@ -36,6 +42,6 @@ namespace Telegrator.Handlers.Components
         /// <param name="container">The <see cref="IHandlerContainer"/> for the update.</param>
         /// <param name="cancellationToken">The cancellation token.</param>
         /// <returns>A <see cref="Task"/> representing the asynchronous operation.</returns>
-        protected abstract Task ExecuteInternal(IHandlerContainer container, CancellationToken cancellationToken);
+        protected abstract Task<Result> ExecuteInternal(IHandlerContainer container, CancellationToken cancellationToken);
     }
 }

Telegrator/Handlers/Result.cs

@@ -0,0 +1,30 @@
+namespace Telegrator.Handlers
+{
+    public sealed class Result
+    {
+        public bool Positive { get; }
+
+        public bool RouteNext { get; }
+
+        public Type? NextType { get; }
+
+        internal Result(bool positive, bool routeNext, Type? nextType)
+        {
+            Positive = positive;
+            RouteNext = routeNext;
+            NextType = nextType;
+        }
+
+        public static Result Ok()
+            => new Result(true, false, null);
+
+        public static Result Fault()
+            => new Result(false, false, null);
+
+        public static Result Next()
+            => new Result(true, true, null);
+
+        public static Result Next<T>()
+            => new Result(true, true, typeof(T));
+    }
+}

Telegrator/MadiatorCore/Descriptors/DefaultCustomDescriptors.cs

@@ -15,6 +15,8 @@ namespace Telegrator.MadiatorCore.Descriptors
     /// <typeparam name="TUpdate"></typeparam>
     public class MethodHandlerDescriptor<TUpdate> : HandlerDescriptor where TUpdate : class
     {
+        private readonly MethodInfo Method;
+
         /// <summary>
         /// Initializes new instance of <see cref="MethodHandlerDescriptor{TUpdate}"/>
         /// </summary>
@@ -28,15 +30,23 @@ namespace Telegrator.MadiatorCore.Descriptors
             UpdateType = handlerAttribute.Type;
             Indexer = handlerAttribute.GetIndexer();
             Filters = new DescriptorFiltersSet(handlerAttribute, stateKeeperAttribute, filters);
-            DisplayString = HandlerInspector.GetDisplayName(action.Method);
+            DisplayString = HandlerInspector.GetDisplayName(action.Method) ?? action.Method.Name;
-            InstanceFactory = () => new MethodHandler(action.Method, UpdateType);
+            Method = action.Method;
+            InstanceFactory = () => new MethodHandler(UpdateType);
+            LazyInitialization = handler =>
+            {
+                if (handler is not MethodHandler methodHandler)
+                    throw new InvalidDataException();
+
+                methodHandler.Method = Method;
+            };
         }
 
-        private class MethodHandler(MethodInfo method, UpdateType updateType) : AbstractUpdateHandler<TUpdate>(updateType)
+        private class MethodHandler(UpdateType updateType) : AbstractUpdateHandler<TUpdate>(updateType)
         {
-            private readonly MethodInfo Method = method;
+            internal MethodInfo Method = null!;
 
-            public override async Task Execute(IAbstractHandlerContainer<TUpdate> container, CancellationToken cancellation)
+            public override async Task<Result> Execute(IAbstractHandlerContainer<TUpdate> container, CancellationToken cancellation)
             {
                 if (Method is null)
                     throw new Exception();
@@ -44,16 +54,15 @@ namespace Telegrator.MadiatorCore.Descriptors
                 if (Method.ReturnType == typeof(void))
                 {
                     Method.Invoke(this, [container, cancellation]);
-                    return;
+                    return Result.Ok();
                 }
                 else
                 {
                     object branchReturn = Method.Invoke(this, [container, cancellation]);
-                    if (branchReturn == null)
+                    if (branchReturn is not Task<Result> branchTask)
-                        return;
+                        throw new InvalidOperationException();
 
-                    if (branchReturn is Task branchTask)
+                    return await branchTask;
-                        await branchTask;
                 }
             }
         }

Telegrator/MadiatorCore/Descriptors/DescribedHandlerInfo.cs

@@ -2,6 +2,7 @@
 using Telegram.Bot.Polling;
 using Telegram.Bot.Types;
 using Telegrator.Filters.Components;
+using Telegrator.Handlers;
 using Telegrator.Handlers.Components;
 
 namespace Telegrator.MadiatorCore.Descriptors
@@ -81,36 +82,43 @@ namespace Telegrator.MadiatorCore.Descriptors
         /// <param name="cancellationToken">Cancellation token.</param>
         /// <returns>A task representing the asynchronous operation.</returns>
         /// <exception cref="Exception">Thrown if the handler lifetime has ended or the handler is not a container factory.</exception>
-        public async Task Execute(CancellationToken cancellationToken)
+        public async Task<Result> Execute(CancellationToken cancellationToken)
         {
             if (HandlerLifetime.IsEnded)
                 throw new Exception();
 
-            IHandlerContainerFactory? containerFactory = HandlerInstance is IHandlerContainerFactory handlerDefainedContainerFactory
-                ? handlerDefainedContainerFactory
-                : UpdateRouter.DefaultContainerFactory is not null
-                    ? UpdateRouter.DefaultContainerFactory
-                    : throw new Exception();
-
             try
             {
-                HandlerContainer = containerFactory.CreateContainer(UpdateRouter.AwaitingProvider,  this);
+                HandlerContainer = GetContainer(UpdateRouter.AwaitingProvider, this);
-                await HandlerInstance.Execute(HandlerContainer, cancellationToken);
+                return await HandlerInstance.Execute(HandlerContainer, cancellationToken);
             }
             catch (OperationCanceledException)
             {
                 // Cancelled
                 _ = 0xBAD + 0xC0DE;
-                return;
+                return Result.Ok();
             }
             catch (Exception exception)
             {
                 await UpdateRouter
                     .HandleErrorAsync(Client, exception, HandleErrorSource.HandleUpdateError, cancellationToken)
                     .ConfigureAwait(false);
+
+                return Result.Fault();
             }
         }
 
+        private IHandlerContainer GetContainer(IAwaitingProvider awaitingProvider, DescribedHandlerInfo handlerInfo)
+        {
+            if (HandlerInstance is IHandlerContainerFactory handlerDefainedContainerFactory)
+                return handlerDefainedContainerFactory.CreateContainer(awaitingProvider, handlerInfo);
+
+            if (UpdateRouter.DefaultContainerFactory is not null)
+                return UpdateRouter.DefaultContainerFactory.CreateContainer(awaitingProvider, handlerInfo);
+            
+            throw new Exception();
+        }
+
         /// <inheritdoc/>
         public override string ToString()
             => DisplayString ?? HandlerInstance.GetType().Name;

Telegrator/MadiatorCore/IUpdateHandlersPool.cs

@@ -7,6 +7,7 @@ namespace Telegrator.MadiatorCore
     /// </summary>
     /// <param name="args">The <see cref="DescribedHandlerInfo"/> for the enqueued handler.</param>
     public delegate void HandlerEnqueued(DescribedHandlerInfo args);
+
     /// <summary>
     /// Represents a delegate for when a handler is executing.
     /// </summary>
@@ -24,7 +25,7 @@ namespace Telegrator.MadiatorCore
         public event HandlerEnqueued? HandlerEnqueued;
         
         /// <summary>
-        /// Occurs when a handler is executing.
+        /// Occurs when a handler is entering execution.
         /// </summary>
         public event HandlerExecuting? HandlerExecuting;
 
@@ -32,8 +33,9 @@ namespace Telegrator.MadiatorCore
         /// Enqueues a collection of handlers for execution.
         /// </summary>
         /// <param name="handlers">The handlers to enqueue.</param>
-        public void Enqueue(IEnumerable<DescribedHandlerInfo> handlers);
+        public Task Enqueue(IEnumerable<DescribedHandlerInfo> handlers);
 
+        /*
         /// <summary>
         /// Enqueues a single handler for execution.
         /// </summary>
@@ -45,5 +47,6 @@ namespace Telegrator.MadiatorCore
         /// </summary>
         /// <param name="token">The <see cref="HandlerLifetimeToken"/> of the handler to dequeue.</param>
         public void Dequeue(HandlerLifetimeToken token);
+        */
     }
 }

Telegrator/Polling/LimitedDictionary.cs

@@ -0,0 +1,52 @@
+using System.Collections;
+using System.Collections.Concurrent;
+
+namespace Telegrator.Polling
+{
+    public class LimitedDictionary<TKey, TValue> : IEnumerable<KeyValuePair<TKey, TValue>>, IDisposable
+    {
+        private readonly int? _maximum;
+        private readonly SemaphoreSlim _semaphore = null!;
+        private readonly ConcurrentDictionary<TKey, TValue> _dict = [];
+
+        public LimitedDictionary(int? maximum)
+        {
+            _maximum = maximum;
+            if (maximum != null)
+            {
+                int value = maximum.Value;
+                _semaphore = new SemaphoreSlim(value, value);
+            }
+        }
+
+        public async Task<bool> Add(TKey key, TValue value, CancellationToken cancellationToken)
+        {
+            if (_semaphore != null)
+                await _semaphore.WaitAsync(cancellationToken).ConfigureAwait(false);
+
+            return _dict.TryAdd(key, value);
+        }
+
+        public bool Remove(TKey key, out TValue result)
+        {
+            if (_dict.TryRemove(key, out result))
+            {
+                _semaphore?.Release(1);
+                return true;
+            }
+
+            return false;
+        }
+
+        public IEnumerator<KeyValuePair<TKey, TValue>> GetEnumerator() => _dict.GetEnumerator();
+
+        IEnumerator IEnumerable.GetEnumerator() => _dict.GetEnumerator();
+
+        /// <inheritdoc/>
+        public void Dispose()
+        {
+            GC.SuppressFinalize(this);
+            _semaphore.Dispose();
+        }
+    }
+}

Telegrator/Polling/LimitedQueue.cs

@@ -0,0 +1,42 @@
+using System.Collections.Concurrent;
+
+namespace Telegrator.Polling
+{
+    public class LimitedQueue<T>
+    {
+        private readonly int? _maximum;
+        private readonly ConcurrentQueue<T> _queue = [];
+        private readonly SemaphoreSlim _semaphore = null!;
+
+        public LimitedQueue(int? maximum)
+        {
+            _maximum = maximum;
+            if (maximum != null)
+            {
+                int value = maximum.Value;
+                _semaphore = new SemaphoreSlim(value, value);
+            }
+        }
+
+        public async Task Enqueue(T item, CancellationToken cancellationToken)
+        {
+            if (_maximum.HasValue)
+                await _semaphore.WaitAsync(cancellationToken);
+
+            _queue.Enqueue(item);
+        }
+
+        public bool Dequeue(out T result)
+        {
+            if (_queue.TryDequeue(out result))
+            {
+                if (_maximum.HasValue)
+                    _semaphore?.Release(1);
+
+                return true;
+            }
+
+            return false;
+        }
+    }
+}

Telegrator/Polling/UpdateHandlersPool.cs

@@ -1,4 +1,5 @@
 using System.Collections.Concurrent;
+using Telegrator.Handlers;
 using Telegrator.MadiatorCore;
 using Telegrator.MadiatorCore.Descriptors;
 
@@ -15,6 +16,7 @@ namespace Telegrator.Polling
         /// </summary>
         protected object SyncObj = new object();
 
+        /*
         /// <summary>
         /// Event that signals when awaiting handlers are queued.
         /// </summary>
@@ -34,6 +36,13 @@ namespace Telegrator.Polling
         /// Dictionary for tracking currently executing handlers.
         /// </summary>
         protected readonly ConcurrentDictionary<HandlerLifetimeToken, Task> ExecutingHandlersPool = [];
+        */
+
+        //protected readonly ConcurrentDictionary<Type, LimitedQueue<DescribedHandlerInfo>> AwaitingHandlersQueue;
+
+        //protected readonly LimitedDictionary<HandlerLifetimeToken, Task> ExecutingHandlersPool;
+
+        protected SemaphoreSlim ExecutingHandlersSemaphore = null!;
 
         /// <summary>
         /// The bot configuration options.
@@ -65,26 +74,62 @@ namespace Telegrator.Polling
         {
             Options = options;
             GlobalCancellationToken = globalCancellationToken;
+            //AwaitingHandlersQueue = new ConcurrentDictionary<Type, LimitedQueue<DescribedHandlerInfo>>();
+            //ExecutingHandlersPool = new LimitedDictionary<HandlerLifetimeToken, Task>(options.MaximumParallelWorkingHandlers);
 
             if (options.MaximumParallelWorkingHandlers != null)
             {
-                ExecutingHandlersSemaphore = new SemaphoreSlim(options.MaximumParallelWorkingHandlers ?? 0);
+                ExecutingHandlersSemaphore = new SemaphoreSlim(options.MaximumParallelWorkingHandlers.Value);
-                AwaitingHandlersQueuedEvent = new ManualResetEventSlim(false);
+                //AwaitingHandlersQueuedEvent = new ManualResetEventSlim(false);
             }
 
+            /*
             if (Options.MaximumParallelWorkingHandlers != null)
                 HandlersCheckpoint();
+            */
         }
 
         /// <inheritdoc/>
-        public void Enqueue(IEnumerable<DescribedHandlerInfo> handlers)
+        public async Task Enqueue(IEnumerable<DescribedHandlerInfo> handlers)
         {
-            handlers.ForEach(Enqueue);
+            //handlers.ForEach(Enqueue);
+
+            Result? lastResult = null;
+            foreach (DescribedHandlerInfo handlerInfo in handlers)
+            {
+                if (lastResult?.NextType != null)
+                {
+                    if (lastResult.NextType != handlerInfo.HandlerInstance.GetType())
+                        continue;
                 }
 
+                if (ExecutingHandlersSemaphore != null)
+                {
+                    await ExecutingHandlersSemaphore.WaitAsync();
+                }
+
+                try
+                {
+                    HandlerExecuting?.Invoke(handlerInfo);
+                    lastResult = await handlerInfo.Execute(GlobalCancellationToken);
+                    ExecutingHandlersSemaphore?.Release(1);
+                }
+                catch (OperationCanceledException)
+                {
+                    break;
+                }
+
+                if (!lastResult.RouteNext)
+                    break;
+            }
+        }
+        
+        /*
         /// <inheritdoc/>
         public void Enqueue(DescribedHandlerInfo handlerInfo)
         {
+            throw new NotImplementedException();
+
             if (Options.MaximumParallelWorkingHandlers == null)
             {
                 Task.Run(async () => await ExecuteHandlerWrapper(handlerInfo));
@@ -111,7 +156,9 @@ namespace Telegrator.Polling
                 ExecutingHandlersSemaphore.Release(1);
             }
         }
+        */
 
+        /*
         /// <summary>
         /// Main checkpoint method that manages handler execution in a loop.
         /// Continuously processes queued handlers while respecting concurrency limits.
@@ -206,6 +253,7 @@ namespace Telegrator.Polling
                 return AwaitingHandlersQueue.TryDequeue(out enqueuedHandler);
             }
         }
+        */
 
         /// <summary>
         /// Disposes of the handlers pool and releases all resources.
@@ -221,11 +269,13 @@ namespace Telegrator.Polling
                 ExecutingHandlersSemaphore = null!;
             }
 
+            /*
             if (AwaitingHandlersQueuedEvent != null)
             {
                 AwaitingHandlersQueuedEvent.Dispose();
                 AwaitingHandlersQueuedEvent = null!;
             }
+            */
 
             if (SyncObj != null)
                 SyncObj = null!;

Telegrator/Polling/UpdateRouter.cs

@@ -96,7 +96,7 @@ namespace Telegrator.Polling
         /// <param name="update">The update to handle.</param>
         /// <param name="cancellationToken">The cancellation token.</param>
         /// <returns>A task representing the asynchronous update handling operation.</returns>
-        public virtual Task HandleUpdateAsync(ITelegramBotClient botClient, Update update, CancellationToken cancellationToken)
+        public virtual async Task HandleUpdateAsync(ITelegramBotClient botClient, Update update, CancellationToken cancellationToken)
         {
             // Logging
             Alligator.RouterWriteLine("Received Update ({0}) of type \"{1}\"", update.Id, update.Type);
@@ -109,31 +109,28 @@ namespace Telegrator.Polling
                 if (handlers.Any())
                 {
                     // Enqueuing found awiting handlers
-                    HandlersPool.Enqueue(handlers);
+                    await HandlersPool.Enqueue(handlers);
 
                     // Chicking if awaiting handlers has exclusive routing
                     if (Options.ExclusiveAwaitingHandlerRouting)
                     {
                         Alligator.RouterWriteLine("Receiving Update ({0}) completed with only awaiting handlers", update.Id);
-                        return Task.CompletedTask;
+                        return;
                     }
                 }
 
                 // Queuing reagular handlers for execution
-                HandlersPool.Enqueue(GetHandlers(HandlersProvider, this, botClient, update, cancellationToken));
+                await HandlersPool.Enqueue(GetHandlers(HandlersProvider, this, botClient, update, cancellationToken));
                 Alligator.RouterWriteLine("Receiving Update ({0}) finished", update.Id);
-                return Task.CompletedTask;
             }
             catch (OperationCanceledException)
             {
                 Alligator.RouterWriteLine("Receiving Update ({0}) cancelled", update.Id);
-                return Task.CompletedTask;
             }
             catch (Exception ex)
             {
                 Alligator.RouterWriteLine("Receiving Update ({0}) finished with exception {1}", update.Id, ex.Message);
                 ExceptionHandler?.HandleException(botClient, ex, HandleErrorSource.PollingError, cancellationToken);
-                return Task.CompletedTask;
             }
         }
 
@@ -162,10 +159,11 @@ namespace Telegrator.Polling
                 return [];
             }
 
-            IEnumerable<DescribedHandlerInfo> described = DescribeDescriptors(provider, descriptors, updateRouter, client, update, cancellationToken);
+            //IEnumerable<DescribedHandlerInfo> described = DescribeDescriptors(provider, descriptors, updateRouter, client, update, cancellationToken);
-            Alligator.RouterWriteLine("Described total of {0} handlers for Update ({1}) from {2} provider", described.Count(), update.Id, provider.GetType().Name);
+            //Alligator.RouterWriteLine("Described total of {0} handlers for Update ({1}) from {2} provider", described.Count(), update.Id, provider.GetType().Name);
-            Alligator.RouterWriteLine("Described handlers : {0}", string.Join(", ", described));
+            //Alligator.RouterWriteLine("Described handlers : {0}", string.Join(", ", described));
-            return described;
+
+            return DescribeDescriptors(provider, descriptors, updateRouter, client, update, cancellationToken);
         }
 
         /// <summary>
@@ -192,8 +190,11 @@ namespace Telegrator.Polling
                         continue;
 
                     yield return describedHandler;
+
+                    /*
                     if (Options.ExecuteOnlyFirstFoundHanlder)
                         break;
+                    */
                 }
             }
             finally

Telegrator/TelegratorOptions.cs

@@ -8,23 +8,24 @@ namespace Telegrator
     /// </summary>
     public class TelegratorOptions : ITelegratorOptions
     {
+        /*
         /// <inheritdoc/>
         public bool ExecuteOnlyFirstFoundHanlder { get; set; }
 
+        /// <inheritdoc/>
+        public bool DescendDescriptorIndex { get; set; } = true;
+        */
+
         /// <inheritdoc/>
         public int? MaximumParallelWorkingHandlers { get; set; }
 
         /// <inheritdoc/>
         public bool ExclusiveAwaitingHandlerRouting { get; set; }
 
-        /// <inheritdoc/>
-        public CancellationToken GlobalCancellationToken { get; set; }
-
-        /// <inheritdoc/>
-        public bool DescendDescriptorIndex { get; set; } = true;
-
         /// <inheritdoc/>
         public bool ExceptIntersectingCommandAliases { get; set; } = true;
 
+        /// <inheritdoc/>
+        public CancellationToken GlobalCancellationToken { get; set; }
     }
 }