class AbstractRSocket
implements RSocket
import { AbstractRSocket } from "https://deno.land/x/rsocket@0.3.0/mod.ts";
Methods
availability(): number
close(): void
fireAndForget(payload: Payload): Promise<void>
metadataPush(payload: Payload): Promise<void>
requestChannel(payloads: Publisher<Payload>): Publisher<Payload>
requestResponse(payload: Payload): Promise<Payload>
requestStream(payload: Payload): Publisher<Payload>