Skip to content

Commit 187af2e

Browse files
devhl-labsdevhl-labs
authored
removed a using statement (OpenAPITools#20541)
1 parent 8b52b0a commit 187af2e

File tree

35 files changed

+255
-290
lines changed

35 files changed

+255
-290
lines changed

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

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
using System;
88
using System.Collections.Generic;
99
using System.Linq;
10-
using System.Threading.Channels;
1110

1211
namespace {{packageName}}.{{clientPackage}}
1312
{
@@ -17,7 +16,7 @@ namespace {{packageName}}.{{clientPackage}}
1716
/// <typeparam name="TTokenBase"></typeparam>
1817
{{>visibility}} class RateLimitProvider<TTokenBase> : TokenProvider<TTokenBase> where TTokenBase : TokenBase
1918
{
20-
internal Dictionary<string, Channel<TTokenBase>> AvailableTokens { get; } = new{{^net70OrLater}} Dictionary<string, Channel<TTokenBase>>{{/net70OrLater}}();
19+
internal Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new{{^net70OrLater}} Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>>{{/net70OrLater}}();
2120

2221
/// <summary>
2322
/// Instantiates a ThrottledTokenProvider. Your tokens will be rate limited based on the token's timeout.
@@ -29,12 +28,12 @@ namespace {{packageName}}.{{clientPackage}}
2928
token.StartTimer(token.Timeout ?? TimeSpan.FromMilliseconds(40));
3029
3130
{{#lambda.copy}}
32-
BoundedChannelOptions options = new BoundedChannelOptions(_tokens.Length)
31+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(_tokens.Length)
3332
{
34-
FullMode = BoundedChannelFullMode.DropWrite
33+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
3534
};
3635

37-
AvailableTokens.Add(string.Empty, Channel.CreateBounded<TTokenBase>(options));
36+
AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
3837
{{/lambda.copy}}
3938
{{#hasApiKeyMethods}}
4039
if (container is TokenContainer<ApiKeyToken> apiKeyTokenContainer)
@@ -43,12 +42,12 @@ namespace {{packageName}}.{{clientPackage}}
4342
4443
foreach (string header in headers)
4544
{
46-
BoundedChannelOptions options = new BoundedChannelOptions(apiKeyTokenContainer.Tokens.Count(t => ClientUtils.ApiKeyHeaderToString(t.Header).Equals(header)))
45+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(apiKeyTokenContainer.Tokens.Count(t => ClientUtils.ApiKeyHeaderToString(t.Header).Equals(header)))
4746
{
48-
FullMode = BoundedChannelFullMode.DropWrite
47+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
4948
};
5049

51-
AvailableTokens.Add(header, Channel.CreateBounded<TTokenBase>(options));
50+
AvailableTokens.Add(header, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
5251
}
5352
}
5453
else
@@ -64,14 +63,14 @@ namespace {{packageName}}.{{clientPackage}}
6463
{{/lambda.paste}}
6564
{{/hasApiKeyMethods}}
6665

67-
foreach(Channel<TTokenBase> tokens in AvailableTokens.Values)
66+
foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
6867
for (int i = 0; i < _tokens.Length; i++)
6968
_tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
7069
}
7170

7271
internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default{{^netstandard20OrLater}}(global::System.Threading.CancellationToken){{/netstandard20OrLater}})
7372
{
74-
if (!AvailableTokens.TryGetValue(header, out Channel<TTokenBase>{{nrt?}} tokens))
73+
if (!AvailableTokens.TryGetValue(header, out global::System.Threading.Channels.Channel<TTokenBase>{{nrt?}} tokens))
7574
throw new KeyNotFoundException($"Could not locate a token for header '{header}'.");
7675

7776
return await tokens.Reader.ReadAsync(cancellation).ConfigureAwait(false);

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

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@
1414
using System;
1515
using System.Collections.Generic;
1616
using System.Linq;
17-
using System.Threading.Channels;
1817

1918
namespace Org.OpenAPITools.Client
2019
{
@@ -24,7 +23,7 @@ namespace Org.OpenAPITools.Client
2423
/// <typeparam name="TTokenBase"></typeparam>
2524
public class RateLimitProvider<TTokenBase> : TokenProvider<TTokenBase> where TTokenBase : TokenBase
2625
{
27-
internal Dictionary<string, Channel<TTokenBase>> AvailableTokens { get; } = new();
26+
internal Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new();
2827

2928
/// <summary>
3029
/// Instantiates a ThrottledTokenProvider. Your tokens will be rate limited based on the token's timeout.
@@ -41,32 +40,32 @@ public RateLimitProvider(TokenContainer<TTokenBase> container) : base(container.
4140

4241
foreach (string header in headers)
4342
{
44-
BoundedChannelOptions options = new BoundedChannelOptions(apiKeyTokenContainer.Tokens.Count(t => ClientUtils.ApiKeyHeaderToString(t.Header).Equals(header)))
43+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(apiKeyTokenContainer.Tokens.Count(t => ClientUtils.ApiKeyHeaderToString(t.Header).Equals(header)))
4544
{
46-
FullMode = BoundedChannelFullMode.DropWrite
45+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
4746
};
4847

49-
AvailableTokens.Add(header, Channel.CreateBounded<TTokenBase>(options));
48+
AvailableTokens.Add(header, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
5049
}
5150
}
5251
else
5352
{
54-
BoundedChannelOptions options = new BoundedChannelOptions(_tokens.Length)
53+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(_tokens.Length)
5554
{
56-
FullMode = BoundedChannelFullMode.DropWrite
55+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
5756
};
5857

59-
AvailableTokens.Add(string.Empty, Channel.CreateBounded<TTokenBase>(options));
58+
AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
6059
}
6160

62-
foreach(Channel<TTokenBase> tokens in AvailableTokens.Values)
61+
foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
6362
for (int i = 0; i < _tokens.Length; i++)
6463
_tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
6564
}
6665

6766
internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)
6867
{
69-
if (!AvailableTokens.TryGetValue(header, out Channel<TTokenBase>? tokens))
68+
if (!AvailableTokens.TryGetValue(header, out global::System.Threading.Channels.Channel<TTokenBase>? tokens))
7069
throw new KeyNotFoundException($"Could not locate a token for header '{header}'.");
7170

7271
return await tokens.Reader.ReadAsync(cancellation).ConfigureAwait(false);

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

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
using System;
1212
using System.Collections.Generic;
1313
using System.Linq;
14-
using System.Threading.Channels;
1514

1615
namespace Org.OpenAPITools.Client
1716
{
@@ -21,7 +20,7 @@ namespace Org.OpenAPITools.Client
2120
/// <typeparam name="TTokenBase"></typeparam>
2221
public class RateLimitProvider<TTokenBase> : TokenProvider<TTokenBase> where TTokenBase : TokenBase
2322
{
24-
internal Dictionary<string, Channel<TTokenBase>> AvailableTokens { get; } = new Dictionary<string, Channel<TTokenBase>>();
23+
internal Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>>();
2524

2625
/// <summary>
2726
/// Instantiates a ThrottledTokenProvider. Your tokens will be rate limited based on the token's timeout.
@@ -32,21 +31,21 @@ public RateLimitProvider(TokenContainer<TTokenBase> container) : base(container.
3231
foreach(TTokenBase token in _tokens)
3332
token.StartTimer(token.Timeout ?? TimeSpan.FromMilliseconds(40));
3433

35-
BoundedChannelOptions options = new BoundedChannelOptions(_tokens.Length)
34+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(_tokens.Length)
3635
{
37-
FullMode = BoundedChannelFullMode.DropWrite
36+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
3837
};
3938

40-
AvailableTokens.Add(string.Empty, Channel.CreateBounded<TTokenBase>(options));
39+
AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
4140

42-
foreach(Channel<TTokenBase> tokens in AvailableTokens.Values)
41+
foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
4342
for (int i = 0; i < _tokens.Length; i++)
4443
_tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
4544
}
4645

4746
internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)
4847
{
49-
if (!AvailableTokens.TryGetValue(header, out Channel<TTokenBase> tokens))
48+
if (!AvailableTokens.TryGetValue(header, out global::System.Threading.Channels.Channel<TTokenBase> tokens))
5049
throw new KeyNotFoundException($"Could not locate a token for header '{header}'.");
5150

5251
return await tokens.Reader.ReadAsync(cancellation).ConfigureAwait(false);

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

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
using System;
1212
using System.Collections.Generic;
1313
using System.Linq;
14-
using System.Threading.Channels;
1514

1615
namespace Org.OpenAPITools.Client
1716
{
@@ -21,7 +20,7 @@ namespace Org.OpenAPITools.Client
2120
/// <typeparam name="TTokenBase"></typeparam>
2221
public class RateLimitProvider<TTokenBase> : TokenProvider<TTokenBase> where TTokenBase : TokenBase
2322
{
24-
internal Dictionary<string, Channel<TTokenBase>> AvailableTokens { get; } = new Dictionary<string, Channel<TTokenBase>>();
23+
internal Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>>();
2524

2625
/// <summary>
2726
/// Instantiates a ThrottledTokenProvider. Your tokens will be rate limited based on the token's timeout.
@@ -32,21 +31,21 @@ public RateLimitProvider(TokenContainer<TTokenBase> container) : base(container.
3231
foreach(TTokenBase token in _tokens)
3332
token.StartTimer(token.Timeout ?? TimeSpan.FromMilliseconds(40));
3433

35-
BoundedChannelOptions options = new BoundedChannelOptions(_tokens.Length)
34+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(_tokens.Length)
3635
{
37-
FullMode = BoundedChannelFullMode.DropWrite
36+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
3837
};
3938

40-
AvailableTokens.Add(string.Empty, Channel.CreateBounded<TTokenBase>(options));
39+
AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
4140

42-
foreach(Channel<TTokenBase> tokens in AvailableTokens.Values)
41+
foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
4342
for (int i = 0; i < _tokens.Length; i++)
4443
_tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
4544
}
4645

4746
internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)
4847
{
49-
if (!AvailableTokens.TryGetValue(header, out Channel<TTokenBase> tokens))
48+
if (!AvailableTokens.TryGetValue(header, out global::System.Threading.Channels.Channel<TTokenBase> tokens))
5049
throw new KeyNotFoundException($"Could not locate a token for header '{header}'.");
5150

5251
return await tokens.Reader.ReadAsync(cancellation).ConfigureAwait(false);

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

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
using System;
1212
using System.Collections.Generic;
1313
using System.Linq;
14-
using System.Threading.Channels;
1514

1615
namespace Org.OpenAPITools.Client
1716
{
@@ -21,7 +20,7 @@ namespace Org.OpenAPITools.Client
2120
/// <typeparam name="TTokenBase"></typeparam>
2221
public class RateLimitProvider<TTokenBase> : TokenProvider<TTokenBase> where TTokenBase : TokenBase
2322
{
24-
internal Dictionary<string, Channel<TTokenBase>> AvailableTokens { get; } = new Dictionary<string, Channel<TTokenBase>>();
23+
internal Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>>();
2524

2625
/// <summary>
2726
/// Instantiates a ThrottledTokenProvider. Your tokens will be rate limited based on the token's timeout.
@@ -32,21 +31,21 @@ public RateLimitProvider(TokenContainer<TTokenBase> container) : base(container.
3231
foreach(TTokenBase token in _tokens)
3332
token.StartTimer(token.Timeout ?? TimeSpan.FromMilliseconds(40));
3433

35-
BoundedChannelOptions options = new BoundedChannelOptions(_tokens.Length)
34+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(_tokens.Length)
3635
{
37-
FullMode = BoundedChannelFullMode.DropWrite
36+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
3837
};
3938

40-
AvailableTokens.Add(string.Empty, Channel.CreateBounded<TTokenBase>(options));
39+
AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
4140

42-
foreach(Channel<TTokenBase> tokens in AvailableTokens.Values)
41+
foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
4342
for (int i = 0; i < _tokens.Length; i++)
4443
_tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
4544
}
4645

4746
internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)
4847
{
49-
if (!AvailableTokens.TryGetValue(header, out Channel<TTokenBase> tokens))
48+
if (!AvailableTokens.TryGetValue(header, out global::System.Threading.Channels.Channel<TTokenBase> tokens))
5049
throw new KeyNotFoundException($"Could not locate a token for header '{header}'.");
5150

5251
return await tokens.Reader.ReadAsync(cancellation).ConfigureAwait(false);

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

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
using System;
1212
using System.Collections.Generic;
1313
using System.Linq;
14-
using System.Threading.Channels;
1514

1615
namespace Org.OpenAPITools.Client
1716
{
@@ -21,7 +20,7 @@ namespace Org.OpenAPITools.Client
2120
/// <typeparam name="TTokenBase"></typeparam>
2221
public class RateLimitProvider<TTokenBase> : TokenProvider<TTokenBase> where TTokenBase : TokenBase
2322
{
24-
internal Dictionary<string, Channel<TTokenBase>> AvailableTokens { get; } = new Dictionary<string, Channel<TTokenBase>>();
23+
internal Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>>();
2524

2625
/// <summary>
2726
/// Instantiates a ThrottledTokenProvider. Your tokens will be rate limited based on the token's timeout.
@@ -38,32 +37,32 @@ public RateLimitProvider(TokenContainer<TTokenBase> container) : base(container.
3837

3938
foreach (string header in headers)
4039
{
41-
BoundedChannelOptions options = new BoundedChannelOptions(apiKeyTokenContainer.Tokens.Count(t => ClientUtils.ApiKeyHeaderToString(t.Header).Equals(header)))
40+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(apiKeyTokenContainer.Tokens.Count(t => ClientUtils.ApiKeyHeaderToString(t.Header).Equals(header)))
4241
{
43-
FullMode = BoundedChannelFullMode.DropWrite
42+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
4443
};
4544

46-
AvailableTokens.Add(header, Channel.CreateBounded<TTokenBase>(options));
45+
AvailableTokens.Add(header, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
4746
}
4847
}
4948
else
5049
{
51-
BoundedChannelOptions options = new BoundedChannelOptions(_tokens.Length)
50+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(_tokens.Length)
5251
{
53-
FullMode = BoundedChannelFullMode.DropWrite
52+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
5453
};
5554

56-
AvailableTokens.Add(string.Empty, Channel.CreateBounded<TTokenBase>(options));
55+
AvailableTokens.Add(string.Empty, global::System.Threading.Channels.Channel.CreateBounded<TTokenBase>(options));
5756
}
5857

59-
foreach(Channel<TTokenBase> tokens in AvailableTokens.Values)
58+
foreach(global::System.Threading.Channels.Channel<TTokenBase> tokens in AvailableTokens.Values)
6059
for (int i = 0; i < _tokens.Length; i++)
6160
_tokens[i].TokenBecameAvailable += ((sender) => tokens.Writer.TryWrite((TTokenBase) sender));
6261
}
6362

6463
internal override async System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default)
6564
{
66-
if (!AvailableTokens.TryGetValue(header, out Channel<TTokenBase> tokens))
65+
if (!AvailableTokens.TryGetValue(header, out global::System.Threading.Channels.Channel<TTokenBase> tokens))
6766
throw new KeyNotFoundException($"Could not locate a token for header '{header}'.");
6867

6968
return await tokens.Reader.ReadAsync(cancellation).ConfigureAwait(false);

0 commit comments

Comments
 (0)