Skip to main content
Module

x/rsocket/mod.ts>RSocketConnector

🦕RSocket Deno module
linux-china/rsocket-deno
Latest
class RSocketConnector
import { RSocketConnector } from "https://deno.land/x/rsocket@0.3.0/mod.ts";

Properties

private
_acceptor: SocketAcceptor | undefined
private
_dataMimeType: string
private
_errorConsumer: ((error: RSocketError) => void) | undefined
private
_keepAliveInterval: number
private
_keepAliveMaxLifeTime: number
private
_metadataMimeType: string
private
_payload: Payload | undefined

Methods

connect(url: string): Promise<RSocket>
dataMimeType(dataMimeType: string): RSocketConnector
errorConsumer(errorConsumer: (error: RSocketError) => void): RSocketConnector
keepAlive(interval: number, maxLifeTime: number): RSocketConnector
metadataMimeType(metadataMimeType: string): RSocketConnector