samples: some samples incorrectly called publishMessage without await (#2035)

I just noticed this while doing something unrelated.

Author: feywind

samples/publishMessage.js

@@ -51,7 +51,7 @@ async function publishMessage(topicNameOrId, data) {
   const topic = pubSubClient.topic(topicNameOrId);
 
   try {
-    const messageId = topic.publishMessage({data: dataBuffer});
+    const messageId = await topic.publishMessage({data: dataBuffer});
     console.log(`Message ${messageId} published.`);
   } catch (error) {
     console.error(`Received error while publishing: ${error.message}`);

samples/publishMessageWithCustomAttributes.js

@@ -55,7 +55,7 @@ async function publishMessageWithCustomAttributes(topicNameOrId, data) {
   // Cache topic objects (publishers) and reuse them.
   const topic = pubSubClient.topic(topicNameOrId);
 
-  const messageId = topic.publishMessage({
+  const messageId = await topic.publishMessage({
     data: dataBuffer,
     attributes: customAttributes,
   });

samples/publishOrderedMessage.js

@@ -72,7 +72,7 @@ async function publishOrderedMessage(topicNameOrId, data, orderingKey) {
   const topic = pubSubClient.topic(topicNameOrId, publishOptions);
 
   // Publishes the message
-  const messageId = topic.publishMessage(message);
+  const messageId = await topic.publishMessage(message);
 
   console.log(`Message ${messageId} published.`);
 

samples/system-test/schema.test.ts

@@ -383,7 +383,7 @@ describe('schema', () => {
     const topic = await createTopicWithSchema(id, schema.id, Encodings.Json);
     const sub = await createSub(id, topic.name);
 
-    topic.publishMessage({
+    await topic.publishMessage({
       data: Buffer.from(
         JSON.stringify({
           name: 'Alberta',
@@ -419,7 +419,7 @@ describe('schema', () => {
     );
     const sub = await createSub(id, topic.name);
 
-    topic.publishMessage({
+    await topic.publishMessage({
       data: Buffer.from(
         JSON.stringify({
           name: 'Alberta',
@@ -443,7 +443,7 @@ describe('schema', () => {
     const topic = await createTopicWithSchema(id, schema.id, Encodings.Json);
     const sub = await createSub(id, topic.name);
 
-    topic.publishMessage({
+    await topic.publishMessage({
       data: Buffer.from(
         JSON.stringify({
           name: 'Quebec',

samples/typescript/publishMessage.ts

@@ -47,7 +47,7 @@ async function publishMessage(topicNameOrId: string, data: string) {
   const topic = pubSubClient.topic(topicNameOrId);
 
   try {
-    const messageId = topic.publishMessage({data: dataBuffer});
+    const messageId = await topic.publishMessage({data: dataBuffer});
     console.log(`Message ${messageId} published.`);
   } catch (error) {
     console.error(

samples/typescript/publishMessageWithCustomAttributes.ts

@@ -58,7 +58,7 @@ async function publishMessageWithCustomAttributes(
   // Cache topic objects (publishers) and reuse them.
   const topic = pubSubClient.topic(topicNameOrId);
 
-  const messageId = topic.publishMessage({
+  const messageId = await topic.publishMessage({
     data: dataBuffer,
     attributes: customAttributes,
   });

samples/typescript/publishOrderedMessage.ts

@@ -72,7 +72,7 @@ async function publishOrderedMessage(
   const topic = pubSubClient.topic(topicNameOrId, publishOptions);
 
   // Publishes the message
-  const messageId = topic.publishMessage(message);
+  const messageId = await topic.publishMessage(message);
 
   console.log(`Message ${messageId} published.`);