Comparing version
@@ -10,8 +10,8 @@ import { InvokeFn, Handler } from './handler.js'; | ||
private lookups; | ||
get lookupMethodFunc(): LookupMethod; | ||
get lookupMethod(): LookupMethod; | ||
register(handler: Handler): void; | ||
registerLookupMethod(lookupMethod: LookupMethod): void; | ||
lookupMethod(serviceID: string, methodID: string): Promise<InvokeFn | null>; | ||
private _lookupMethod; | ||
private lookupViaMap; | ||
private lookupViaLookups; | ||
} |
@@ -13,5 +13,5 @@ // createMux builds a new StaticMux. | ||
lookups = []; | ||
// lookupMethodFunc implements the LookupMethod type. | ||
get lookupMethodFunc() { | ||
return this.lookupMethod.bind(this); | ||
// lookupMethod implements the LookupMethod type. | ||
get lookupMethod() { | ||
return this._lookupMethod.bind(this); | ||
} | ||
@@ -34,3 +34,3 @@ register(handler) { | ||
} | ||
async lookupMethod(serviceID, methodID) { | ||
async _lookupMethod(serviceID, methodID) { | ||
if (serviceID) { | ||
@@ -37,0 +37,0 @@ const invokeFn = await this.lookupViaMap(serviceID, methodID); |
@@ -10,3 +10,3 @@ import { describe, it, beforeEach } from 'vitest'; | ||
const mux = createMux(); | ||
const server = new Server(mux.lookupMethodFunc); | ||
const server = new Server(mux.lookupMethod); | ||
const echoer = new EchoerServer(server); | ||
@@ -13,0 +13,0 @@ mux.register(createHandler(EchoerDefinition, echoer)); |
{ | ||
"name": "starpc", | ||
"version": "0.36.3", | ||
"version": "0.36.4", | ||
"description": "Streaming protobuf RPC service protocol over any two-way channel.", | ||
@@ -5,0 +5,0 @@ "license": "MIT", |
@@ -169,3 +169,3 @@ # Stream RPC (starpc) | ||
mux.register(createHandler(EchoerDefinition, echoer)) | ||
const server = new Server(mux.lookupMethodFunc) | ||
const server = new Server(mux.lookupMethod) | ||
@@ -172,0 +172,0 @@ // Create the client connection to the server with an in-memory pipe. |
@@ -33,5 +33,5 @@ import { InvokeFn, Handler } from './handler.js' | ||
// lookupMethodFunc implements the LookupMethod type. | ||
public get lookupMethodFunc(): LookupMethod { | ||
return this.lookupMethod.bind(this) | ||
// lookupMethod implements the LookupMethod type. | ||
public get lookupMethod(): LookupMethod { | ||
return this._lookupMethod.bind(this) | ||
} | ||
@@ -57,3 +57,3 @@ | ||
public async lookupMethod( | ||
private async _lookupMethod( | ||
serviceID: string, | ||
@@ -60,0 +60,0 @@ methodID: string, |
@@ -24,3 +24,3 @@ import { describe, it, beforeEach } from 'vitest' | ||
const mux = createMux() | ||
const server = new Server(mux.lookupMethodFunc) | ||
const server = new Server(mux.lookupMethod) | ||
const echoer = new EchoerServer(server) | ||
@@ -27,0 +27,0 @@ mux.register(createHandler(EchoerDefinition, echoer)) |
390261
-0.02%