@sebspark/pubsub
Advanced tools
Comparing version 1.5.0 to 1.5.1
@@ -116,3 +116,3 @@ "use strict"; | ||
var import_pubsub2 = require("@google-cloud/pubsub"); | ||
var makeSureSubacriptionExists = async (topic, name, options) => { | ||
var makeSureSubscriptionExists = async (topic, name, options) => { | ||
const createSubscriptionOptions = { | ||
@@ -140,11 +140,8 @@ messageRetentionDuration: { | ||
topic: (name) => { | ||
let _topic; | ||
const _topic = client.topic(name); | ||
return { | ||
initiate: async (subscriptionName, options) => { | ||
await makeSureSubacriptionExists(_topic, subscriptionName, options); | ||
await makeSureSubscriptionExists(_topic, subscriptionName, options); | ||
}, | ||
subscribe: async (subscriptionName, callbacks, options) => { | ||
if (!_topic) { | ||
_topic = client.topic(name); | ||
} | ||
const subscription = _topic.subscription(subscriptionName); | ||
@@ -151,0 +148,0 @@ subscription.on("message", async (msg) => { |
{ | ||
"name": "@sebspark/pubsub", | ||
"version": "1.5.0", | ||
"version": "1.5.1", | ||
"license": "Apache-2.0", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
Sorry, the diff of this file is not supported yet
24999
347