@nestjs-plugins/nestjs-nats-jetstream-transport
Advanced tools
Comparing version 1.3.1 to 1.3.2
@@ -1,2 +0,2 @@ | ||
import { PubAck } from "nats"; | ||
import { NatsConnection, PubAck } from "nats"; | ||
import { Observable } from "rxjs"; | ||
@@ -9,4 +9,4 @@ import { NatsJetStreamClientProxy } from "./client"; | ||
send<TInput>(pattern: any, data: TInput): Observable<PubAck>; | ||
connect(): void; | ||
close(): void; | ||
connect(): Promise<NatsConnection>; | ||
close(): Promise<void>; | ||
} |
@@ -25,7 +25,7 @@ "use strict"; | ||
} | ||
connect() { | ||
this.connect(); | ||
async connect() { | ||
return this.client.connect(); | ||
} | ||
close() { | ||
this.close(); | ||
async close() { | ||
return this.client.close(); | ||
} | ||
@@ -32,0 +32,0 @@ }; |
{ | ||
"name": "@nestjs-plugins/nestjs-nats-jetstream-transport", | ||
"version": "1.3.1", | ||
"version": "1.3.2", | ||
"description": "Nats JetStream Transport for NestJS", | ||
@@ -33,3 +33,3 @@ "main": "dist/index.js", | ||
"dependencies": { | ||
"@nestjs-plugins/nestjs-nats-jetstream-transport": "^1.3.1", | ||
"@nestjs-plugins/nestjs-nats-jetstream-transport": "^1.3.2", | ||
"nats": "^2.6.1", | ||
@@ -46,3 +46,3 @@ "reflect-metadata": "^0.1.13", | ||
}, | ||
"gitHead": "d749a2a4d5a14ecb5ebb0392596a0a64ee6dfd28" | ||
"gitHead": "7402f6ed313571e6aa3249a4b8b2dfbf73855c36" | ||
} |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
147908