fixed token availablity (#21326)

modules/openapi-generator/src/main/resources/csharp/libraries/generichost/RateLimitProvider`1.mustache

@@ -63,9 +63,25 @@ namespace {{packageName}}.{{clientPackage}}
             {{/lambda.paste}}
             {{/hasApiKeyMethods}}
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    {{#hasApiKeyMethods}}
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                    {{/hasApiKeyMethods}}
+                    {{^hasApiKeyMethods}}
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    {{/hasApiKeyMethods}}
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default{{^netstandard20OrLater}}(global::System.Threading.CancellationToken){{/netstandard20OrLater}})

samples/client/petstore/csharp/generichost/latest/HelloWorld/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -40,9 +40,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/latest/OneOfList/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -40,9 +40,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/latest/Tags/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -58,9 +58,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.7/AllOf/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -38,9 +38,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.7/AnyOf/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -38,9 +38,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.7/AnyOfNoCompare/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -38,9 +38,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.7/FormModels/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -55,9 +55,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.7/OneOf/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -38,9 +38,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.7/Petstore/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -55,9 +55,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.7/UseDateTimeForDate/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -38,9 +38,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.8/AllOf/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -38,9 +38,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.8/AnyOf/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -38,9 +38,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.8/AnyOfNoCompare/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -38,9 +38,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.8/FormModels/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -55,9 +55,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.8/OneOf/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -38,9 +38,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.8/Petstore/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -55,9 +55,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net4.8/UseDateTimeForDate/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -38,9 +38,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net8/AllOf/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -40,9 +40,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net8/AnyOf/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -40,9 +40,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net8/AnyOfNoCompare/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -40,9 +40,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net8/FormModels/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -55,9 +55,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net8/NullReferenceTypes/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -57,9 +57,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net8/OneOf/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -40,9 +40,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net8/Petstore/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -55,9 +55,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net8/SourceGeneration/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -57,9 +57,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net8/UseDateTimeForDate/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -40,9 +40,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net9/AllOf/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -40,9 +40,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net9/AnyOf/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -40,9 +40,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net9/AnyOfNoCompare/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -40,9 +40,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net9/FormModels/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -55,9 +55,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net9/NullReferenceTypes/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -57,9 +57,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net9/OneOf/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -40,9 +40,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net9/Petstore/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -55,9 +55,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net9/SourceGeneration/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -57,9 +57,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/net9/UseDateTimeForDate/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -40,9 +40,11 @@ namespace Org.OpenAPITools.Client
 
             AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)

samples/client/petstore/csharp/generichost/standard2.0/Petstore/src/Org.OpenAPITools/Client/RateLimitProvider`1.cs

@@ -55,9 +55,20 @@ namespace Org.OpenAPITools.Client
                 AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
             }
 
-            foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
+            foreach (var availableToken in AvailableTokens)
-                for (int i = 0; i < _tokens.Length; i++)
+                foreach(TTokenBase token in _tokens)
-                    _tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
+                {
+                    if (token is ApiKeyToken apiKeyToken)
+                    {
+                        if (ClientUtils.ApiKeyHeaderToString(apiKeyToken.Header) == availableToken.Key)
+                        {
+                            token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                        }
+                    } else
+                    {
+                        token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
+                    }
+                }
         }
 
         internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)