class RSocketRequester
implements RSocket
import { RSocketRequester } from "https://deno.land/x/rsocket@0.3.0/rsocket/core/RSocketRequester.ts";
Constructors
Properties
private
readonly
_connection: DuplexConnectionprivate
readonly
_connectionSetupPayload: ConnectionSetupPayloadprivate
_errorConsumer: ((error: RSocketError) => void) | undefinedprivate
_responder: RSocketprivate
_streamIdSupplier: StreamIdSupplierprivate
senders: Map<number, Subscriber<Payload>>writeonly
errorConsumer: ((error: RSocketError) => void) | undefinedwriteonly
responder: RSocket | undefinedMethods
private
setupPayloadFrame(): Uint8Arrayavailability(): number
close(): void
fireAndForget(payload: Payload)
metadataPush(payload: Payload)
receiveFrame(frame: any)
requestChannel(payloads: Publisher<Payload>): Publisher<Payload>
requestResponse(payload: Payload): Promise<Payload>
requestStream(payload: Payload): Publisher<Payload>