Skip to content

Commit 9df6acc

Browse files
fix examples
1 parent 14cbc1c commit 9df6acc

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

examples/src/BasicExample/ReadTable.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ internal partial class BasicExample
66
{
77
private async Task ReadTable()
88
{
9-
var readStream = Client.ReadTable(
9+
var readStream = await Client.ReadTable(
1010
FullTablePath("seasons"),
1111
new ReadTableSettings
1212
{

examples/src/BasicExample/ScanQuery.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ FROM episodes
1818
ORDER BY series_id, season_id;
1919
";
2020

21-
var scanStream = Client.ExecuteScanQuery(
21+
var scanStream = await Client.ExecuteScanQuery(
2222
query,
2323
new Dictionary<string, YdbValue>
2424
{

examples/src/QueryExample/QueryExample.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -231,7 +231,7 @@ private async Task StreamSelect()
231231

232232
await Client.DoTx(async tx =>
233233
{
234-
await foreach (var part in tx.Stream(query, commit: true))
234+
await foreach (var part in await tx.Stream(query, commit: true))
235235
{
236236
foreach (var row in part.ResultSet!.Rows)
237237
{
@@ -316,7 +316,7 @@ private async Task ReadAllResultSets()
316316
var resultSets = await Client.DoTx(async tx =>
317317
{
318318
var resultSets = new List<Value.ResultSet>();
319-
await foreach (var resultSet in tx.Stream(query, commit: true))
319+
await foreach (var resultSet in await tx.Stream(query, commit: true))
320320
{
321321
resultSets.Add(resultSet.ResultSet!);
322322
}

0 commit comments

Comments
 (0)