diff --git a/src/libs/Cohere/Generated/Cohere.CohereApi.Chat.g.cs b/src/libs/Cohere/Generated/Cohere.CohereApi.Chat.g.cs index 060ab032..37ced252 100644 --- a/src/libs/Cohere/Generated/Cohere.CohereApi.Chat.g.cs +++ b/src/libs/Cohere/Generated/Cohere.CohereApi.Chat.g.cs @@ -505,12 +505,10 @@ partial void ProcessChatResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.OneOf.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.OneOf.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.CohereApi.Chatv2.g.cs b/src/libs/Cohere/Generated/Cohere.CohereApi.Chatv2.g.cs index 6d13c0aa..0b2ac1ba 100644 --- a/src/libs/Cohere/Generated/Cohere.CohereApi.Chatv2.g.cs +++ b/src/libs/Cohere/Generated/Cohere.CohereApi.Chatv2.g.cs @@ -495,12 +495,10 @@ partial void ProcessChatv2ResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.OneOf.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.OneOf.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.CohereApi.CheckAPIKey.g.cs b/src/libs/Cohere/Generated/Cohere.CohereApi.CheckAPIKey.g.cs index d2d131d0..d1271328 100644 --- a/src/libs/Cohere/Generated/Cohere.CohereApi.CheckAPIKey.g.cs +++ b/src/libs/Cohere/Generated/Cohere.CohereApi.CheckAPIKey.g.cs @@ -480,12 +480,10 @@ partial void ProcessCheckAPIKeyResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.CheckAPIKeyResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.CheckAPIKeyResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.CohereApi.Classify.g.cs b/src/libs/Cohere/Generated/Cohere.CohereApi.Classify.g.cs index 50f4652c..31ee30de 100644 --- a/src/libs/Cohere/Generated/Cohere.CohereApi.Classify.g.cs +++ b/src/libs/Cohere/Generated/Cohere.CohereApi.Classify.g.cs @@ -495,12 +495,10 @@ partial void ProcessClassifyResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.ClassifyResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.ClassifyResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.CohereApi.Detokenize.g.cs b/src/libs/Cohere/Generated/Cohere.CohereApi.Detokenize.g.cs index db9ba6dd..e8518554 100644 --- a/src/libs/Cohere/Generated/Cohere.CohereApi.Detokenize.g.cs +++ b/src/libs/Cohere/Generated/Cohere.CohereApi.Detokenize.g.cs @@ -494,12 +494,10 @@ partial void ProcessDetokenizeResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.DetokenizeResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.DetokenizeResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.CohereApi.Embed.g.cs b/src/libs/Cohere/Generated/Cohere.CohereApi.Embed.g.cs index cfa290a3..cc62f8f5 100644 --- a/src/libs/Cohere/Generated/Cohere.CohereApi.Embed.g.cs +++ b/src/libs/Cohere/Generated/Cohere.CohereApi.Embed.g.cs @@ -496,12 +496,10 @@ partial void ProcessEmbedResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.OneOf.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.OneOf.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.CohereApi.Embedv2.g.cs b/src/libs/Cohere/Generated/Cohere.CohereApi.Embedv2.g.cs index e4febb86..33f78fe6 100644 --- a/src/libs/Cohere/Generated/Cohere.CohereApi.Embedv2.g.cs +++ b/src/libs/Cohere/Generated/Cohere.CohereApi.Embedv2.g.cs @@ -496,12 +496,10 @@ partial void ProcessEmbedv2ResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.EmbedByTypeResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.EmbedByTypeResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.CohereApi.Generate.g.cs b/src/libs/Cohere/Generated/Cohere.CohereApi.Generate.g.cs index 8cc51c17..328cc896 100644 --- a/src/libs/Cohere/Generated/Cohere.CohereApi.Generate.g.cs +++ b/src/libs/Cohere/Generated/Cohere.CohereApi.Generate.g.cs @@ -497,12 +497,10 @@ partial void ProcessGenerateResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.Generation.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.Generation.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.CohereApi.Rerank.g.cs b/src/libs/Cohere/Generated/Cohere.CohereApi.Rerank.g.cs index 4b5d5f5c..2db99372 100644 --- a/src/libs/Cohere/Generated/Cohere.CohereApi.Rerank.g.cs +++ b/src/libs/Cohere/Generated/Cohere.CohereApi.Rerank.g.cs @@ -494,12 +494,10 @@ partial void ProcessRerankResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.RerankResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.RerankResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.CohereApi.Rerankv2.g.cs b/src/libs/Cohere/Generated/Cohere.CohereApi.Rerankv2.g.cs index c178a015..5cfb696c 100644 --- a/src/libs/Cohere/Generated/Cohere.CohereApi.Rerankv2.g.cs +++ b/src/libs/Cohere/Generated/Cohere.CohereApi.Rerankv2.g.cs @@ -494,12 +494,10 @@ partial void ProcessRerankv2ResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.Rerankv2Response.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.Rerankv2Response.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.CohereApi.Summarize.g.cs b/src/libs/Cohere/Generated/Cohere.CohereApi.Summarize.g.cs index baf3b60e..69958a8d 100644 --- a/src/libs/Cohere/Generated/Cohere.CohereApi.Summarize.g.cs +++ b/src/libs/Cohere/Generated/Cohere.CohereApi.Summarize.g.cs @@ -497,12 +497,10 @@ partial void ProcessSummarizeResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.SummarizeResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.SummarizeResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.CohereApi.Tokenize.g.cs b/src/libs/Cohere/Generated/Cohere.CohereApi.Tokenize.g.cs index 48c130c2..b123ca17 100644 --- a/src/libs/Cohere/Generated/Cohere.CohereApi.Tokenize.g.cs +++ b/src/libs/Cohere/Generated/Cohere.CohereApi.Tokenize.g.cs @@ -494,12 +494,10 @@ partial void ProcessTokenizeResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.TokenizeResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.TokenizeResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.ConnectorsClient.CreateConnector.g.cs b/src/libs/Cohere/Generated/Cohere.ConnectorsClient.CreateConnector.g.cs index 5d62e08f..92f7f212 100644 --- a/src/libs/Cohere/Generated/Cohere.ConnectorsClient.CreateConnector.g.cs +++ b/src/libs/Cohere/Generated/Cohere.ConnectorsClient.CreateConnector.g.cs @@ -494,12 +494,10 @@ partial void ProcessCreateConnectorResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.CreateConnectorResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.CreateConnectorResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.ConnectorsClient.DeleteConnector.g.cs b/src/libs/Cohere/Generated/Cohere.ConnectorsClient.DeleteConnector.g.cs index b2c344a2..db505dad 100644 --- a/src/libs/Cohere/Generated/Cohere.ConnectorsClient.DeleteConnector.g.cs +++ b/src/libs/Cohere/Generated/Cohere.ConnectorsClient.DeleteConnector.g.cs @@ -462,7 +462,7 @@ partial void ProcessDeleteConnectorResponseContent( }; } - return __content; + return __content; } else { @@ -484,13 +484,9 @@ partial void ProcessDeleteConnectorResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::System.Text.Json.JsonSerializer.DeserializeAsync(__responseStream, typeof(string), JsonSerializerContext).ConfigureAwait(false) as string; + var __content = await __response.Content.ReadAsStringAsync(cancellationToken).ConfigureAwait(false); - return - __responseValue ?? - throw new global::System.InvalidOperationException("Response deserialization failed."); + return __content; } } } diff --git a/src/libs/Cohere/Generated/Cohere.ConnectorsClient.GetConnector.g.cs b/src/libs/Cohere/Generated/Cohere.ConnectorsClient.GetConnector.g.cs index abe0b263..ed149fab 100644 --- a/src/libs/Cohere/Generated/Cohere.ConnectorsClient.GetConnector.g.cs +++ b/src/libs/Cohere/Generated/Cohere.ConnectorsClient.GetConnector.g.cs @@ -486,12 +486,10 @@ partial void ProcessGetConnectorResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.GetConnectorResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.GetConnectorResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.ConnectorsClient.ListConnectors.g.cs b/src/libs/Cohere/Generated/Cohere.ConnectorsClient.ListConnectors.g.cs index a212fcf8..186ae819 100644 --- a/src/libs/Cohere/Generated/Cohere.ConnectorsClient.ListConnectors.g.cs +++ b/src/libs/Cohere/Generated/Cohere.ConnectorsClient.ListConnectors.g.cs @@ -500,12 +500,10 @@ partial void ProcessListConnectorsResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.ListConnectorsResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.ListConnectorsResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.ConnectorsClient.OAuthAuthorizeConnector.g.cs b/src/libs/Cohere/Generated/Cohere.ConnectorsClient.OAuthAuthorizeConnector.g.cs index 34c4fa74..c5241025 100644 --- a/src/libs/Cohere/Generated/Cohere.ConnectorsClient.OAuthAuthorizeConnector.g.cs +++ b/src/libs/Cohere/Generated/Cohere.ConnectorsClient.OAuthAuthorizeConnector.g.cs @@ -495,12 +495,10 @@ partial void ProcessOAuthAuthorizeConnectorResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.OAuthAuthorizeResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.OAuthAuthorizeResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.ConnectorsClient.UpdateConnector.g.cs b/src/libs/Cohere/Generated/Cohere.ConnectorsClient.UpdateConnector.g.cs index 9cba6c37..b4d64ec1 100644 --- a/src/libs/Cohere/Generated/Cohere.ConnectorsClient.UpdateConnector.g.cs +++ b/src/libs/Cohere/Generated/Cohere.ConnectorsClient.UpdateConnector.g.cs @@ -500,12 +500,10 @@ partial void ProcessUpdateConnectorResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.UpdateConnectorResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.UpdateConnectorResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.DatasetsClient.CreateDataset.g.cs b/src/libs/Cohere/Generated/Cohere.DatasetsClient.CreateDataset.g.cs index 710ad07b..2b196333 100644 --- a/src/libs/Cohere/Generated/Cohere.DatasetsClient.CreateDataset.g.cs +++ b/src/libs/Cohere/Generated/Cohere.DatasetsClient.CreateDataset.g.cs @@ -609,12 +609,10 @@ partial void ProcessCreateDatasetResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.CreateDatasetResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.CreateDatasetResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.DatasetsClient.DeleteDataset.g.cs b/src/libs/Cohere/Generated/Cohere.DatasetsClient.DeleteDataset.g.cs index 73c94423..86d76e47 100644 --- a/src/libs/Cohere/Generated/Cohere.DatasetsClient.DeleteDataset.g.cs +++ b/src/libs/Cohere/Generated/Cohere.DatasetsClient.DeleteDataset.g.cs @@ -462,7 +462,7 @@ partial void ProcessDeleteDatasetResponseContent( }; } - return __content; + return __content; } else { @@ -484,13 +484,9 @@ partial void ProcessDeleteDatasetResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::System.Text.Json.JsonSerializer.DeserializeAsync(__responseStream, typeof(string), JsonSerializerContext).ConfigureAwait(false) as string; + var __content = await __response.Content.ReadAsStringAsync(cancellationToken).ConfigureAwait(false); - return - __responseValue ?? - throw new global::System.InvalidOperationException("Response deserialization failed."); + return __content; } } } diff --git a/src/libs/Cohere/Generated/Cohere.DatasetsClient.GetDataset.g.cs b/src/libs/Cohere/Generated/Cohere.DatasetsClient.GetDataset.g.cs index 120790d7..92c06fcd 100644 --- a/src/libs/Cohere/Generated/Cohere.DatasetsClient.GetDataset.g.cs +++ b/src/libs/Cohere/Generated/Cohere.DatasetsClient.GetDataset.g.cs @@ -486,12 +486,10 @@ partial void ProcessGetDatasetResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.GetDatasetResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.GetDatasetResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.DatasetsClient.GetDatasetUsage.g.cs b/src/libs/Cohere/Generated/Cohere.DatasetsClient.GetDatasetUsage.g.cs index 5eb55a19..1d10e8e5 100644 --- a/src/libs/Cohere/Generated/Cohere.DatasetsClient.GetDatasetUsage.g.cs +++ b/src/libs/Cohere/Generated/Cohere.DatasetsClient.GetDatasetUsage.g.cs @@ -480,12 +480,10 @@ partial void ProcessGetDatasetUsageResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.GetDatasetUsageResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.GetDatasetUsageResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.DatasetsClient.ListDatasets.g.cs b/src/libs/Cohere/Generated/Cohere.DatasetsClient.ListDatasets.g.cs index 1ad74cd0..4f1de1ad 100644 --- a/src/libs/Cohere/Generated/Cohere.DatasetsClient.ListDatasets.g.cs +++ b/src/libs/Cohere/Generated/Cohere.DatasetsClient.ListDatasets.g.cs @@ -526,12 +526,10 @@ partial void ProcessListDatasetsResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.ListDatasetsResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.ListDatasetsResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.EmbedJobsClient.CreateEmbedJob.g.cs b/src/libs/Cohere/Generated/Cohere.EmbedJobsClient.CreateEmbedJob.g.cs index 2f178268..916f153d 100644 --- a/src/libs/Cohere/Generated/Cohere.EmbedJobsClient.CreateEmbedJob.g.cs +++ b/src/libs/Cohere/Generated/Cohere.EmbedJobsClient.CreateEmbedJob.g.cs @@ -494,12 +494,10 @@ partial void ProcessCreateEmbedJobResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.CreateEmbedJobResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.CreateEmbedJobResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.EmbedJobsClient.GetEmbedJob.g.cs b/src/libs/Cohere/Generated/Cohere.EmbedJobsClient.GetEmbedJob.g.cs index e05c7713..e4400411 100644 --- a/src/libs/Cohere/Generated/Cohere.EmbedJobsClient.GetEmbedJob.g.cs +++ b/src/libs/Cohere/Generated/Cohere.EmbedJobsClient.GetEmbedJob.g.cs @@ -486,12 +486,10 @@ partial void ProcessGetEmbedJobResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.EmbedJob.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.EmbedJob.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.EmbedJobsClient.ListEmbedJobs.g.cs b/src/libs/Cohere/Generated/Cohere.EmbedJobsClient.ListEmbedJobs.g.cs index fe186940..f9323627 100644 --- a/src/libs/Cohere/Generated/Cohere.EmbedJobsClient.ListEmbedJobs.g.cs +++ b/src/libs/Cohere/Generated/Cohere.EmbedJobsClient.ListEmbedJobs.g.cs @@ -480,12 +480,10 @@ partial void ProcessListEmbedJobsResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.ListEmbedJobResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.ListEmbedJobResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.FinetuningClient.CreateFinetunedModel.g.cs b/src/libs/Cohere/Generated/Cohere.FinetuningClient.CreateFinetunedModel.g.cs index 13a9e5b9..1542bfef 100644 --- a/src/libs/Cohere/Generated/Cohere.FinetuningClient.CreateFinetunedModel.g.cs +++ b/src/libs/Cohere/Generated/Cohere.FinetuningClient.CreateFinetunedModel.g.cs @@ -325,12 +325,10 @@ partial void ProcessCreateFinetunedModelResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.CreateFinetunedModelResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.CreateFinetunedModelResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.FinetuningClient.DeleteFinetunedModel.g.cs b/src/libs/Cohere/Generated/Cohere.FinetuningClient.DeleteFinetunedModel.g.cs index f83ca8a7..cd111dd6 100644 --- a/src/libs/Cohere/Generated/Cohere.FinetuningClient.DeleteFinetunedModel.g.cs +++ b/src/libs/Cohere/Generated/Cohere.FinetuningClient.DeleteFinetunedModel.g.cs @@ -293,7 +293,7 @@ partial void ProcessDeleteFinetunedModelResponseContent( }; } - return __content; + return __content; } else { @@ -315,13 +315,9 @@ partial void ProcessDeleteFinetunedModelResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::System.Text.Json.JsonSerializer.DeserializeAsync(__responseStream, typeof(string), JsonSerializerContext).ConfigureAwait(false) as string; + var __content = await __response.Content.ReadAsStringAsync(cancellationToken).ConfigureAwait(false); - return - __responseValue ?? - throw new global::System.InvalidOperationException("Response deserialization failed."); + return __content; } } } diff --git a/src/libs/Cohere/Generated/Cohere.FinetuningClient.GetFinetunedModel.g.cs b/src/libs/Cohere/Generated/Cohere.FinetuningClient.GetFinetunedModel.g.cs index 24ba27dc..dad6f928 100644 --- a/src/libs/Cohere/Generated/Cohere.FinetuningClient.GetFinetunedModel.g.cs +++ b/src/libs/Cohere/Generated/Cohere.FinetuningClient.GetFinetunedModel.g.cs @@ -317,12 +317,10 @@ partial void ProcessGetFinetunedModelResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.GetFinetunedModelResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.GetFinetunedModelResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.FinetuningClient.ListEvents.g.cs b/src/libs/Cohere/Generated/Cohere.FinetuningClient.ListEvents.g.cs index 89f2d5aa..9182a989 100644 --- a/src/libs/Cohere/Generated/Cohere.FinetuningClient.ListEvents.g.cs +++ b/src/libs/Cohere/Generated/Cohere.FinetuningClient.ListEvents.g.cs @@ -340,12 +340,10 @@ partial void ProcessListEventsResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.ListEventsResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.ListEventsResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.FinetuningClient.ListFinetunedModels.g.cs b/src/libs/Cohere/Generated/Cohere.FinetuningClient.ListFinetunedModels.g.cs index 74871594..19491e7d 100644 --- a/src/libs/Cohere/Generated/Cohere.FinetuningClient.ListFinetunedModels.g.cs +++ b/src/libs/Cohere/Generated/Cohere.FinetuningClient.ListFinetunedModels.g.cs @@ -334,12 +334,10 @@ partial void ProcessListFinetunedModelsResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.ListFinetunedModelsResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.ListFinetunedModelsResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.FinetuningClient.ListTrainingStepMetrics.g.cs b/src/libs/Cohere/Generated/Cohere.FinetuningClient.ListTrainingStepMetrics.g.cs index ec6612c6..766c5e3b 100644 --- a/src/libs/Cohere/Generated/Cohere.FinetuningClient.ListTrainingStepMetrics.g.cs +++ b/src/libs/Cohere/Generated/Cohere.FinetuningClient.ListTrainingStepMetrics.g.cs @@ -333,12 +333,10 @@ partial void ProcessListTrainingStepMetricsResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.ListTrainingStepMetricsResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.ListTrainingStepMetricsResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.FinetuningClient.UpdateFinetunedModel.g.cs b/src/libs/Cohere/Generated/Cohere.FinetuningClient.UpdateFinetunedModel.g.cs index 51bf27cf..bb24da9d 100644 --- a/src/libs/Cohere/Generated/Cohere.FinetuningClient.UpdateFinetunedModel.g.cs +++ b/src/libs/Cohere/Generated/Cohere.FinetuningClient.UpdateFinetunedModel.g.cs @@ -331,12 +331,10 @@ partial void ProcessUpdateFinetunedModelResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.UpdateFinetunedModelResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.UpdateFinetunedModelResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.Models.AssistantMessage.g.cs b/src/libs/Cohere/Generated/Cohere.Models.AssistantMessage.g.cs index f15f4dc2..5b2d2a51 100644 --- a/src/libs/Cohere/Generated/Cohere.Models.AssistantMessage.g.cs +++ b/src/libs/Cohere/Generated/Cohere.Models.AssistantMessage.g.cs @@ -33,7 +33,7 @@ public sealed partial class AssistantMessage /// /// [global::System.Text.Json.Serialization.JsonPropertyName("content")] - [global::System.Text.Json.Serialization.JsonConverter(typeof(global::Cohere.JsonConverters.OneOfJsonConverterFactory2))] + [global::System.Text.Json.Serialization.JsonConverter(typeof(global::Cohere.JsonConverters.OneOfJsonConverter>>))] public global::Cohere.OneOf>>? Content { get; set; } /// diff --git a/src/libs/Cohere/Generated/Cohere.Models.SystemMessage.g.cs b/src/libs/Cohere/Generated/Cohere.Models.SystemMessage.g.cs index 3f632f17..c59fb31e 100644 --- a/src/libs/Cohere/Generated/Cohere.Models.SystemMessage.g.cs +++ b/src/libs/Cohere/Generated/Cohere.Models.SystemMessage.g.cs @@ -21,7 +21,7 @@ public sealed partial class SystemMessage /// /// [global::System.Text.Json.Serialization.JsonPropertyName("content")] - [global::System.Text.Json.Serialization.JsonConverter(typeof(global::Cohere.JsonConverters.OneOfJsonConverterFactory2))] + [global::System.Text.Json.Serialization.JsonConverter(typeof(global::Cohere.JsonConverters.OneOfJsonConverter>>))] [global::System.Text.Json.Serialization.JsonRequired] public required global::Cohere.OneOf>> Content { get; set; } diff --git a/src/libs/Cohere/Generated/Cohere.Models.ToolMessageV2.g.cs b/src/libs/Cohere/Generated/Cohere.Models.ToolMessageV2.g.cs index 11d77630..07f3fd80 100644 --- a/src/libs/Cohere/Generated/Cohere.Models.ToolMessageV2.g.cs +++ b/src/libs/Cohere/Generated/Cohere.Models.ToolMessageV2.g.cs @@ -28,7 +28,7 @@ public sealed partial class ToolMessageV2 /// Outputs from a tool. The content should formatted as a JSON object string, or a list of tool content blocks /// [global::System.Text.Json.Serialization.JsonPropertyName("content")] - [global::System.Text.Json.Serialization.JsonConverter(typeof(global::Cohere.JsonConverters.OneOfJsonConverterFactory2))] + [global::System.Text.Json.Serialization.JsonConverter(typeof(global::Cohere.JsonConverters.OneOfJsonConverter>))] [global::System.Text.Json.Serialization.JsonRequired] public required global::Cohere.OneOf> Content { get; set; } diff --git a/src/libs/Cohere/Generated/Cohere.Models.UserMessage.g.cs b/src/libs/Cohere/Generated/Cohere.Models.UserMessage.g.cs index fc27881b..5f8570b6 100644 --- a/src/libs/Cohere/Generated/Cohere.Models.UserMessage.g.cs +++ b/src/libs/Cohere/Generated/Cohere.Models.UserMessage.g.cs @@ -22,7 +22,7 @@ public sealed partial class UserMessage /// If a string is provided, it will be treated as a text content block. /// [global::System.Text.Json.Serialization.JsonPropertyName("content")] - [global::System.Text.Json.Serialization.JsonConverter(typeof(global::Cohere.JsonConverters.OneOfJsonConverterFactory2))] + [global::System.Text.Json.Serialization.JsonConverter(typeof(global::Cohere.JsonConverters.OneOfJsonConverter>))] [global::System.Text.Json.Serialization.JsonRequired] public required global::Cohere.OneOf> Content { get; set; } diff --git a/src/libs/Cohere/Generated/Cohere.ModelsClient.GetModel.g.cs b/src/libs/Cohere/Generated/Cohere.ModelsClient.GetModel.g.cs index b33b09b3..431d6999 100644 --- a/src/libs/Cohere/Generated/Cohere.ModelsClient.GetModel.g.cs +++ b/src/libs/Cohere/Generated/Cohere.ModelsClient.GetModel.g.cs @@ -488,12 +488,10 @@ partial void ProcessGetModelResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.GetModelResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.GetModelResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/Cohere.ModelsClient.ListModels.g.cs b/src/libs/Cohere/Generated/Cohere.ModelsClient.ListModels.g.cs index 8f2aa6bc..90aadfe8 100644 --- a/src/libs/Cohere/Generated/Cohere.ModelsClient.ListModels.g.cs +++ b/src/libs/Cohere/Generated/Cohere.ModelsClient.ListModels.g.cs @@ -500,12 +500,10 @@ partial void ProcessListModelsResponseContent( }; } - using var __responseStream = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); - - var __responseValue = await global::Cohere.ListModelsResponse.FromJsonStreamAsync(__responseStream, JsonSerializerContext).ConfigureAwait(false); + using var __content = await __response.Content.ReadAsStreamAsync(cancellationToken).ConfigureAwait(false); return - __responseValue ?? + await global::Cohere.ListModelsResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); } } diff --git a/src/libs/Cohere/Generated/JsonConverters.OneOfFactory1.g.cs b/src/libs/Cohere/Generated/JsonConverters.OneOfFactory1.g.cs deleted file mode 100644 index c93a061a..00000000 --- a/src/libs/Cohere/Generated/JsonConverters.OneOfFactory1.g.cs +++ /dev/null @@ -1,25 +0,0 @@ -#nullable enable - -namespace Cohere.JsonConverters -{ - /// - public sealed class OneOfJsonConverterFactory1 : global::System.Text.Json.Serialization.JsonConverterFactory - { - /// - public override bool CanConvert(global::System.Type? typeToConvert) - { - return typeToConvert is { IsGenericType: true } && typeToConvert.GetGenericTypeDefinition() == typeof(global::Cohere.OneOf<>); - } - - /// - public override global::System.Text.Json.Serialization.JsonConverter CreateConverter( - global::System.Type typeToConvert, - global::System.Text.Json.JsonSerializerOptions options) - { - typeToConvert = typeToConvert ?? throw new global::System.ArgumentNullException(nameof(typeToConvert)); - - return (global::System.Text.Json.Serialization.JsonConverter)global::System.Activator.CreateInstance( - typeof(OneOfJsonConverter<>).MakeGenericType(typeToConvert.GenericTypeArguments))!; - } - } -} diff --git a/src/libs/Cohere/Generated/JsonConverters.OneOfFactory2.g.cs b/src/libs/Cohere/Generated/JsonConverters.OneOfFactory2.g.cs deleted file mode 100644 index c7286681..00000000 --- a/src/libs/Cohere/Generated/JsonConverters.OneOfFactory2.g.cs +++ /dev/null @@ -1,25 +0,0 @@ -#nullable enable - -namespace Cohere.JsonConverters -{ - /// - public sealed class OneOfJsonConverterFactory2 : global::System.Text.Json.Serialization.JsonConverterFactory - { - /// - public override bool CanConvert(global::System.Type? typeToConvert) - { - return typeToConvert is { IsGenericType: true } && typeToConvert.GetGenericTypeDefinition() == typeof(global::Cohere.OneOf<,>); - } - - /// - public override global::System.Text.Json.Serialization.JsonConverter CreateConverter( - global::System.Type typeToConvert, - global::System.Text.Json.JsonSerializerOptions options) - { - typeToConvert = typeToConvert ?? throw new global::System.ArgumentNullException(nameof(typeToConvert)); - - return (global::System.Text.Json.Serialization.JsonConverter)global::System.Activator.CreateInstance( - typeof(OneOfJsonConverter<,>).MakeGenericType(typeToConvert.GenericTypeArguments))!; - } - } -} diff --git a/src/libs/Cohere/Generated/JsonSerializerContext.g.cs b/src/libs/Cohere/Generated/JsonSerializerContext.g.cs index ca1adefc..32ab4559 100644 --- a/src/libs/Cohere/Generated/JsonSerializerContext.g.cs +++ b/src/libs/Cohere/Generated/JsonSerializerContext.g.cs @@ -142,9 +142,7 @@ namespace Cohere typeof(global::Cohere.JsonConverters.ChatDebugEventJsonConverter), typeof(global::Cohere.JsonConverters.StreamedChatResponseJsonConverter), typeof(global::Cohere.JsonConverters.ContentJsonConverter), - typeof(global::Cohere.JsonConverters.OneOfJsonConverterFactory2), typeof(global::Cohere.JsonConverters.SourceJsonConverter), - typeof(global::Cohere.JsonConverters.OneOfJsonConverterFactory1), typeof(global::Cohere.JsonConverters.ToolContentJsonConverter), typeof(global::Cohere.JsonConverters.ChatMessageV2JsonConverter), typeof(global::Cohere.JsonConverters.ResponseFormatV2JsonConverter), @@ -165,6 +163,18 @@ namespace Cohere typeof(global::Cohere.JsonConverters.GenerateStreamEndJsonConverter), typeof(global::Cohere.JsonConverters.GenerateStreamErrorJsonConverter), typeof(global::Cohere.JsonConverters.GenerateStreamedResponseJsonConverter), + typeof(global::Cohere.JsonConverters.OneOfJsonConverter>), + typeof(global::Cohere.JsonConverters.OneOfJsonConverter>>), + typeof(global::Cohere.JsonConverters.OneOfJsonConverter), + typeof(global::Cohere.JsonConverters.OneOfJsonConverter>>), + typeof(global::Cohere.JsonConverters.OneOfJsonConverter), + typeof(global::Cohere.JsonConverters.OneOfJsonConverter>), + typeof(global::Cohere.JsonConverters.OneOfJsonConverter), + typeof(global::Cohere.JsonConverters.OneOfJsonConverter), + typeof(global::Cohere.JsonConverters.OneOfJsonConverter), + typeof(global::Cohere.JsonConverters.OneOfJsonConverter), + typeof(global::Cohere.JsonConverters.OneOfJsonConverter), + typeof(global::Cohere.JsonConverters.OneOfJsonConverter), })] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Cohere.JsonSerializerContextTypes))]