Merge pull request #5 from kaleido-io/activatePool-stream-init

[activatePool-stream-init] initializing stream in /activatepool
hyperledger · Jan 20, 2022 · 2ab302d · 2ab302d
2 parents c339170 + cebf597
commit 2ab302d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/tokens/tokens.service.ts b/src/tokens/tokens.service.ts
@@ -146,6 +146,9 @@ export class TokensService {
   }
 
   async activatePool(dto: TokenPoolActivate) {
+    if(this.stream === undefined) {
+      this.stream = await this.eventstream.createOrUpdateStream(this.topic);
+    }
     await Promise.all([
       this.eventstream.getOrCreateSubscription(
         `${this.baseUrl}/${this.instancePath}`,