TrueCloudLab/frostfs-sdk-csharp
19
0
Fork 4
Code Issues 5 Pull requests Projects Releases Packages Activity Actions

[#1] Read from stream asynchronously

Browse source 
Signed-off-by: Ivan Pchelintsev <i.pchelintsev@yadro.com>
This commit is contained in:
Ivan Pchelintsev 2024-05-21 16:15:19 +03:00
parent cbf6ad5a77
commit 70ba87bc60
2 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
src/FrostFS.SDK.ClientV2/Services/Container.cs
View file

@ -21,6 +21,7 @@ public partial class Client
return response.Body.Container.ToModel(); return response.Body.Container.ToModel();
} }
//TODO: Return iterator
public async Task<ContainerId[]> ListContainersAsync() public async Task<ContainerId[]> ListContainersAsync()
{ {
var request = new ListRequest var request = new ListRequest

5
src/FrostFS.SDK.ClientV2/Services/Object.cs
View file

@ -132,7 +132,7 @@ public partial class Client
using var stream = await PutObjectInit(request); using var stream = await PutObjectInit(request);
var buffer = new byte[Constants.ObjectChunkSize]; var buffer = new byte[Constants.ObjectChunkSize];
var bufferLength = payload.Read(buffer, 0, Constants.ObjectChunkSize); var bufferLength = await payload.ReadAsync(buffer.AsMemory(0, Constants.ObjectChunkSize));
while (bufferLength > 0) while (bufferLength > 0)
{ {
request.Body = new PutRequest.Types.Body request.Body = new PutRequest.Types.Body
@ -142,7 +142,7 @@ public partial class Client
request.VerifyHeader = null; request.VerifyHeader = null;
request.Sign(_key); request.Sign(_key);
await stream.Write(request); await stream.Write(request);
bufferLength = payload.Read(buffer, 0, Constants.ObjectChunkSize); bufferLength = await payload.ReadAsync(buffer.AsMemory(0, Constants.ObjectChunkSize));
} }
var response = await stream.Close(); var response = await stream.Close();
@ -179,6 +179,7 @@ public partial class Client
await _objectServiceClient.DeleteAsync(request); await _objectServiceClient.DeleteAsync(request);
} }
//TODO: Return iterator
public async Task<ObjectId[]> SearchObjectAsync(ContainerId cid, params ObjectFilter[] filters) public async Task<ObjectId[]> SearchObjectAsync(ContainerId cid, params ObjectFilter[] filters)
{ {
var request = new SearchRequest var request = new SearchRequest