import { type RSocket } from "https://deno.land/x/rsocket@0.3.0/rsocket/RSocket.ts";
Methods
fireAndForget(payload: Payload): Promise<void>
Fire and Forget interaction model of ReactiveSocket
. The returned
Publisher resolves when the passed payload
is successfully handled.
Request-Response interaction model of ReactiveSocket
. The returned
Publisher resolves with the response.
Request-Stream interaction model of ReactiveSocket
. The returned
Publisher returns values representing the response(s).
Request-Channel interaction model of ReactiveSocket
. The returned
Publisher returns values representing the response(s).
metadataPush(payload: Payload): Promise<void>
Metadata-Push interaction model of ReactiveSocket
. The returned Publisher
resolves when the passed payload
is successfully handled.