[WIP] service framework

nats-io · Oct 4, 2022 · 8b3f78a · 8b3f78a
1 parent abfc030
commit 8b3f78a
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/nats-base-client/service.ts b/nats-base-client/service.ts
@@ -76,9 +76,9 @@ export function addService(
   nc: NatsConnection,
   kind: string,
   id: string,
-  handler: SrvHandler<any>,
+  handler: SrvHandler<Msg>,
 ): Promise<Srv> {
-  const s = new SrvImpl(nc, kind, id, handler);
+  const s = new SrvImpl(nc, kind, id, handler as SrvHandler);
   try {
     return s.start();
   } catch (err) {
@@ -98,7 +98,7 @@ export class SrvImpl implements Srv {
   _heartbeatInterval: number;
   stopped: boolean;
   watched: Promise<void>[];
-  statuses: Map<SrvHandler<any>, SrvStatusEntry>;
+  statuses: Map<SrvHandler, SrvStatusEntry>;
   interval!: number;
 
   static controlSubject(verb: SrvVerb, kind = "", id = "") {
@@ -179,7 +179,7 @@ export class SrvImpl implements Srv {
       queue: sv.queueGroup ? sv.queueGroup : undefined,
     });
     sv.sub = sub;
-    this.statuses.set(h, status);
+    this.statuses.set(h as SrvHandler<unknown>, status);
 
     sv.sub.closed
       .then(() => {

diff --git a/tests/service_test.ts b/tests/service_test.ts
@@ -14,10 +14,10 @@ Deno.test("svc - basics", async () => {
   const jc = JSONCodec();
 
   const hb = deferred<Msg>();
-  const sub = nc.subscribe(
+  nc.subscribe(
     SrvImpl.controlSubject(SrvVerb.HEARTBEAT, "test", "a"),
     {
-      callback: (err, msg) => {
+      callback: (_err, msg) => {
         hb.resolve(msg);
       },
       max: 1,
@@ -27,7 +27,7 @@ Deno.test("svc - basics", async () => {
   const srv = await addService(nc, "test", "a", {
     name: "x",
     subject: "foo",
-    handler: (err, msg) => {
+    handler: (_err, msg) => {
       msg?.respond();
     },
   });