Skip to content

Commit 1b5141b

Browse files
EraYaNEraYaN
committed
Update samples
1 parent 37ff160 commit 1b5141b

File tree

114 files changed

+394
-1116
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

114 files changed

+394
-1116
lines changed

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

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
* The version of the OpenAPI document: 0.0.1
88
* Generated by: https://github.com/openapitools/openapi-generator.git
99
*/
10-
1110
#nullable enable
1211

1312
using System;
@@ -22,32 +21,32 @@ namespace Org.OpenAPITools.Client
2221
/// <typeparam name="TTokenBase"></typeparam>
2322
public class RateLimitProvider<TTokenBase> : TokenProvider<TTokenBase> where TTokenBase : TokenBase
2423
{
25-
internal Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new();
24+
public Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new();
2625

2726
/// <summary>
2827
/// Instantiates a ThrottledTokenProvider. Your tokens will be rate limited based on the token's timeout.
2928
/// </summary>
3029
/// <param name="container"></param>
31-
public RateLimitProvider(TokenContainer<TTokenBase> container) : base(container.Tokens)
30+
public RateLimitProvider(TokenContainer<TTokenBase> container) : base()
3231
{
33-
foreach(TTokenBase token in _tokens)
32+
foreach(TTokenBase token in container.Tokens)
3433
token.StartTimer(token.Timeout ?? TimeSpan.FromMilliseconds(40));
3534

36-
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(_tokens.Length)
35+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(container.Tokens.Count)
3736
{
38-
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
37+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropOldest
3938
};
4039

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

4342
foreach (var availableToken in AvailableTokens)
44-
foreach(TTokenBase token in _tokens)
43+
foreach(TTokenBase token in container.Tokens)
4544
{
4645
token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
4746
}
4847
}
4948

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

‎samples/client/petstore/csharp/generichost/latest/ComposedEnum/src/Org.OpenAPITools/Client/TokenBase.cs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@ public abstract class TokenBase
1717

1818

1919
internal TimeSpan? Timeout { get; set; }
20-
internal delegate void TokenBecameAvailableEventHandler(object sender);
21-
internal event TokenBecameAvailableEventHandler? TokenBecameAvailable;
20+
public delegate void TokenBecameAvailableEventHandler(object sender);
21+
public event TokenBecameAvailableEventHandler? TokenBecameAvailable;
2222

2323

2424
/// <summary>

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

Lines changed: 1 addition & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
* The version of the OpenAPI document: 0.0.1
88
* Generated by: https://github.com/openapitools/openapi-generator.git
99
*/
10-
1110
#nullable enable
1211

1312
using System;
@@ -22,23 +21,6 @@ namespace Org.OpenAPITools
2221
/// </summary>
2322
public abstract class TokenProvider<TTokenBase> where TTokenBase : TokenBase
2423
{
25-
/// <summary>
26-
/// The array of tokens.
27-
/// </summary>
28-
protected TTokenBase[] _tokens;
29-
30-
internal abstract System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default);
31-
32-
/// <summary>
33-
/// Instantiates a TokenProvider.
34-
/// </summary>
35-
/// <param name="tokens"></param>
36-
public TokenProvider(IEnumerable<TTokenBase> tokens)
37-
{
38-
_tokens = tokens.ToArray();
39-
40-
if (_tokens.Length == 0)
41-
throw new ArgumentException("You did not provide any tokens.");
42-
}
24+
public abstract System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default);
4325
}
4426
}

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

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
* The version of the OpenAPI document: 1.0.0
88
* Generated by: https://github.com/openapitools/openapi-generator.git
99
*/
10-
1110
#nullable enable
1211

1312
using System;
@@ -22,32 +21,32 @@ namespace Org.OpenAPITools.Client
2221
/// <typeparam name="TTokenBase"></typeparam>
2322
public class RateLimitProvider<TTokenBase> : TokenProvider<TTokenBase> where TTokenBase : TokenBase
2423
{
25-
internal Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new();
24+
public Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new();
2625

2726
/// <summary>
2827
/// Instantiates a ThrottledTokenProvider. Your tokens will be rate limited based on the token's timeout.
2928
/// </summary>
3029
/// <param name="container"></param>
31-
public RateLimitProvider(TokenContainer<TTokenBase> container) : base(container.Tokens)
30+
public RateLimitProvider(TokenContainer<TTokenBase> container) : base()
3231
{
33-
foreach(TTokenBase token in _tokens)
32+
foreach(TTokenBase token in container.Tokens)
3433
token.StartTimer(token.Timeout ?? TimeSpan.FromMilliseconds(40));
3534

36-
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(_tokens.Length)
35+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(container.Tokens.Count)
3736
{
38-
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
37+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropOldest
3938
};
4039

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

4342
foreach (var availableToken in AvailableTokens)
44-
foreach(TTokenBase token in _tokens)
43+
foreach(TTokenBase token in container.Tokens)
4544
{
4645
token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
4746
}
4847
}
4948

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

‎samples/client/petstore/csharp/generichost/latest/HelloWorld/src/Org.OpenAPITools/Client/TokenBase.cs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@ public abstract class TokenBase
1717

1818

1919
internal TimeSpan? Timeout { get; set; }
20-
internal delegate void TokenBecameAvailableEventHandler(object sender);
21-
internal event TokenBecameAvailableEventHandler? TokenBecameAvailable;
20+
public delegate void TokenBecameAvailableEventHandler(object sender);
21+
public event TokenBecameAvailableEventHandler? TokenBecameAvailable;
2222

2323

2424
/// <summary>

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

Lines changed: 1 addition & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
* The version of the OpenAPI document: 1.0.0
88
* Generated by: https://github.com/openapitools/openapi-generator.git
99
*/
10-
1110
#nullable enable
1211

1312
using System;
@@ -22,23 +21,6 @@ namespace Org.OpenAPITools
2221
/// </summary>
2322
public abstract class TokenProvider<TTokenBase> where TTokenBase : TokenBase
2423
{
25-
/// <summary>
26-
/// The array of tokens.
27-
/// </summary>
28-
protected TTokenBase[] _tokens;
29-
30-
internal abstract System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default);
31-
32-
/// <summary>
33-
/// Instantiates a TokenProvider.
34-
/// </summary>
35-
/// <param name="tokens"></param>
36-
public TokenProvider(IEnumerable<TTokenBase> tokens)
37-
{
38-
_tokens = tokens.ToArray();
39-
40-
if (_tokens.Length == 0)
41-
throw new ArgumentException("You did not provide any tokens.");
42-
}
24+
public abstract System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default);
4325
}
4426
}

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

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
* The version of the OpenAPI document: 1.0.0
88
* Generated by: https://github.com/openapitools/openapi-generator.git
99
*/
10-
1110
#nullable enable
1211

1312
using System;
@@ -22,32 +21,32 @@ namespace Org.OpenAPITools.Client
2221
/// <typeparam name="TTokenBase"></typeparam>
2322
public class RateLimitProvider<TTokenBase> : TokenProvider<TTokenBase> where TTokenBase : TokenBase
2423
{
25-
internal Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new();
24+
public Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new();
2625

2726
/// <summary>
2827
/// Instantiates a ThrottledTokenProvider. Your tokens will be rate limited based on the token's timeout.
2928
/// </summary>
3029
/// <param name="container"></param>
31-
public RateLimitProvider(TokenContainer<TTokenBase> container) : base(container.Tokens)
30+
public RateLimitProvider(TokenContainer<TTokenBase> container) : base()
3231
{
33-
foreach(TTokenBase token in _tokens)
32+
foreach(TTokenBase token in container.Tokens)
3433
token.StartTimer(token.Timeout ?? TimeSpan.FromMilliseconds(40));
3534

36-
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(_tokens.Length)
35+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(container.Tokens.Count)
3736
{
38-
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
37+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropOldest
3938
};
4039

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

4342
foreach (var availableToken in AvailableTokens)
44-
foreach(TTokenBase token in _tokens)
43+
foreach(TTokenBase token in container.Tokens)
4544
{
4645
token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
4746
}
4847
}
4948

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

‎samples/client/petstore/csharp/generichost/latest/InlineEnumAnyOf/src/Org.OpenAPITools/Client/TokenBase.cs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@ public abstract class TokenBase
1717

1818

1919
internal TimeSpan? Timeout { get; set; }
20-
internal delegate void TokenBecameAvailableEventHandler(object sender);
21-
internal event TokenBecameAvailableEventHandler? TokenBecameAvailable;
20+
public delegate void TokenBecameAvailableEventHandler(object sender);
21+
public event TokenBecameAvailableEventHandler? TokenBecameAvailable;
2222

2323

2424
/// <summary>

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

Lines changed: 1 addition & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
* The version of the OpenAPI document: 1.0.0
88
* Generated by: https://github.com/openapitools/openapi-generator.git
99
*/
10-
1110
#nullable enable
1211

1312
using System;
@@ -22,23 +21,6 @@ namespace Org.OpenAPITools
2221
/// </summary>
2322
public abstract class TokenProvider<TTokenBase> where TTokenBase : TokenBase
2423
{
25-
/// <summary>
26-
/// The array of tokens.
27-
/// </summary>
28-
protected TTokenBase[] _tokens;
29-
30-
internal abstract System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default);
31-
32-
/// <summary>
33-
/// Instantiates a TokenProvider.
34-
/// </summary>
35-
/// <param name="tokens"></param>
36-
public TokenProvider(IEnumerable<TTokenBase> tokens)
37-
{
38-
_tokens = tokens.ToArray();
39-
40-
if (_tokens.Length == 0)
41-
throw new ArgumentException("You did not provide any tokens.");
42-
}
24+
public abstract System.Threading.Tasks.ValueTask<TTokenBase> GetAsync(string header = "", System.Threading.CancellationToken cancellation = default);
4325
}
4426
}

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

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
* The version of the OpenAPI document: 1.0.0
88
* Generated by: https://github.com/openapitools/openapi-generator.git
99
*/
10-
1110
#nullable enable
1211

1312
using System;
@@ -22,32 +21,32 @@ namespace Org.OpenAPITools.Client
2221
/// <typeparam name="TTokenBase"></typeparam>
2322
public class RateLimitProvider<TTokenBase> : TokenProvider<TTokenBase> where TTokenBase : TokenBase
2423
{
25-
internal Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new();
24+
public Dictionary<string, global::System.Threading.Channels.Channel<TTokenBase>> AvailableTokens { get; } = new();
2625

2726
/// <summary>
2827
/// Instantiates a ThrottledTokenProvider. Your tokens will be rate limited based on the token's timeout.
2928
/// </summary>
3029
/// <param name="container"></param>
31-
public RateLimitProvider(TokenContainer<TTokenBase> container) : base(container.Tokens)
30+
public RateLimitProvider(TokenContainer<TTokenBase> container) : base()
3231
{
33-
foreach(TTokenBase token in _tokens)
32+
foreach(TTokenBase token in container.Tokens)
3433
token.StartTimer(token.Timeout ?? TimeSpan.FromMilliseconds(40));
3534

36-
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(_tokens.Length)
35+
global::System.Threading.Channels.BoundedChannelOptions options = new global::System.Threading.Channels.BoundedChannelOptions(container.Tokens.Count)
3736
{
38-
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropWrite
37+
FullMode = global::System.Threading.Channels.BoundedChannelFullMode.DropOldest
3938
};
4039

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

4342
foreach (var availableToken in AvailableTokens)
44-
foreach(TTokenBase token in _tokens)
43+
foreach(TTokenBase token in container.Tokens)
4544
{
4645
token.TokenBecameAvailable += ((sender) => availableToken.Value.Writer.TryWrite((TTokenBase)sender));
4746
}
4847
}
4948

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

0 commit comments

Comments
 (0)