class RSocketRouteHandler
implements RSocket
import { RSocketRouteHandler } from "https://deno.land/x/rsocket@0.3.0/mod.ts";
Methods
addService(serviceName: string, handler: any): void
availability(): number
close(): void
fireAndForget(payload: Payload): Promise<void>
getServiceHandler(serviceName: string, method: string): any | undefined
metadataPush(payload: Payload): Promise<void>
parseRouting(compositeMetadata: CompositeMetadata): ServiceRouting | undefined
requestChannel(payloads: Publisher<Payload>): Publisher<Payload>
requestResponse(payload: Payload): Promise<Payload>
requestStream(payload: Payload): Publisher<Payload>
Static Methods
fromHandler(serviceName: string, handler: any)