Skip to content

Commit

Permalink
Fix streaming API.
Browse files Browse the repository at this point in the history
  • Loading branch information
SebastianStehle committed Nov 10, 2024
1 parent a7bd6d7 commit 42b1512
Show file tree
Hide file tree
Showing 3 changed files with 417 additions and 3 deletions.
2 changes: 1 addition & 1 deletion csharp/Squidex.ClientLibrary/Directory.Build.props
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
<PackageTags>Squidex HeadlessCMS</PackageTags>
<PublishRepositoryUrl>true</PublishRepositoryUrl>
<SymbolPackageFormat>snupkg</SymbolPackageFormat>
<Version>19.7.0</Version>
<Version>20.0.0</Version>
</PropertyGroup>

<PropertyGroup Condition="'$(GITHUB_ACTIONS)' == 'true'">
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,6 @@ public async Task GetAllAsync(Func<TEntity, Task> callback, int batchSize = 200,
var isAnyAdded = false;

var getResult = await GetAsync(query, context, ct);

foreach (var item in getResult.Items)
{
if (added.Add(item.Id))
Expand Down Expand Up @@ -89,7 +88,7 @@ public async Task StreamAllAsync(Func<TEntity, Task> callback, int skip = 0, Que

using (var request = BuildRequest(HttpMethod.Get, BuildUrl($"stream?skip={skip}", false), null, context))
{
using (var response = await httpClient.SendAsync(request, ct))
using (var response = await httpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead, ct))
{
await EnsureResponseIsValidAsync(response);

Expand Down
Loading

0 comments on commit 42b1512

Please sign in to comment.