docs: change samples on exclusive stream to explicitly create them (#449

)
googleapis · May 6, 2024 · 841de04 · 841de04
1 parent 367e934
commit 841de04
Show file tree

Hide file tree

Showing 5 changed files with 20 additions and 14 deletions.
diff --git a/samples/append_rows_buffered.js b/samples/append_rows_buffered.js
@@ -49,14 +49,16 @@ function main(
         'root'
       );
 
-      const connection = await writeClient.createStreamConnection({
+      const streamId = await writeClient.createWriteStream({
         streamType,
         destinationTable,
       });
-
-      const streamId = connection.getStreamId();
       console.log(`Stream created: ${streamId}`);
 
+      const connection = await writeClient.createStreamConnection({
+        streamId,
+      });
+
       const writer = new JSONWriter({
         streamId,
         connection,

diff --git a/samples/append_rows_json_writer_commited.js b/samples/append_rows_json_writer_commited.js
@@ -49,14 +49,16 @@ function main(
         'root'
       );
 
-      const connection = await writeClient.createStreamConnection({
+      const streamId = await writeClient.createWriteStream({
         streamType,
         destinationTable,
       });
-
-      const streamId = connection.getStreamId();
       console.log(`Stream created: ${streamId}`);
 
+      const connection = await writeClient.createStreamConnection({
+        streamId,
+      });
+
       const writer = new JSONWriter({
         streamId,
         connection,

diff --git a/samples/append_rows_pending.js b/samples/append_rows_pending.js
@@ -61,7 +61,6 @@ function main(
       });
       console.log(`Stream created: ${streamId}`);
 
-      // Append data to the given stream.
       const connection = await writeClient.createStreamConnection({
         streamId,
       });

diff --git a/samples/append_rows_proto2.js b/samples/append_rows_proto2.js
@@ -56,15 +56,16 @@ function main(
     const writeClient = new WriterClient({projectId});
 
     try {
-      // Append data to the given stream.
-      const connection = await writeClient.createStreamConnection({
+      const streamId = await writeClient.createWriteStream({
         streamType,
         destinationTable,
       });
-
-      const streamId = connection.getStreamId();
       console.log(`Stream created: ${streamId}`);
 
+      const connection = await writeClient.createStreamConnection({
+        streamId,
+      });
+
       const writer = new Writer({
         connection,
         protoDescriptor,

diff --git a/samples/append_rows_table_to_proto2.js b/samples/append_rows_table_to_proto2.js
@@ -49,14 +49,16 @@ function main(
         'root'
       );
 
-      const connection = await writeClient.createStreamConnection({
+      const streamId = await writeClient.createWriteStream({
         streamType,
         destinationTable,
       });
-
-      const streamId = connection.getStreamId();
       console.log(`Stream created: ${streamId}`);
 
+      const connection = await writeClient.createStreamConnection({
+        streamId,
+      });
+
       const writer = new JSONWriter({
         connection,
         protoDescriptor,