Options
All
  • Public
  • Public/Protected
  • All
Menu

Class RealtimeClient

Hierarchy

  • RealtimeClient

Index

Constructors

Properties

Methods

Constructors

constructor

  • Initializes the Socket.

    Parameters

    • endPoint: string

      The string WebSocket endpoint, ie, "ws://example.com/socket", "wss://example.com", "/socket" (inherited host & protocol)

    • Optional options: RealtimeClientOptions

    Returns RealtimeClient

Properties

Private _workerObjectUrl

_workerObjectUrl: any

accessToken

accessToken: null | (() => Promise<null | string>)

accessTokenValue

accessTokenValue: null | string

apiKey

apiKey: null | string

channels

channels: RealtimeChannel[]

conn

conn: null | WebSocketLike

decode

decode: Function

encode

encode: Function

endPoint

endPoint: string

fetch

fetch: ((input: RequestInfo | URL, init?: RequestInit) => Promise<Response>)

Type declaration

    • (input: RequestInfo | URL, init?: RequestInit): Promise<Response>

    • Parameters

      • input: RequestInfo | URL
      • Optional init: RequestInit

      Returns Promise<Response>

Optional headers

headers?: {}

Type declaration

  • [key: string]: string

heartbeatIntervalMs

heartbeatIntervalMs: number

heartbeatTimer

heartbeatTimer: undefined | Timer

httpEndpoint

httpEndpoint: string

logger

logger: Function

Optional params

params?: {}

Type declaration

  • [key: string]: string

pendingHeartbeatRef

pendingHeartbeatRef: null | string

reconnectAfterMs

reconnectAfterMs: Function

reconnectTimer

reconnectTimer: default

ref

ref: number

sendBuffer

sendBuffer: Function[]

serializer

serializer: default

stateChangeCallbacks

stateChangeCallbacks: { close: Function[]; error: Function[]; message: Function[]; open: Function[] }

Type declaration

  • close: Function[]
  • error: Function[]
  • message: Function[]
  • open: Function[]

timeout

timeout: number

transport

transport: null | WebSocketLikeConstructor

Optional worker

worker?: boolean

Optional workerRef

workerRef?: Worker

Optional workerUrl

workerUrl?: string

Methods

channel

connect

  • connect(): void

  • Connects the socket, unless already connected.

    Returns void

connectionState

  • connectionState(): CONNECTION_STATE

  • Returns the current state of the socket.

    Returns CONNECTION_STATE

disconnect

  • disconnect(code?: number, reason?: string): void

  • Disconnects the socket.

    Parameters

    • Optional code: number

      A numeric status code to send on disconnect.

    • Optional reason: string

      A custom reason for the disconnect.

    Returns void

endpointURL

  • endpointURL(): string

  • Returns the URL of the websocket.

    Returns string

    string The URL of the websocket.

flushSendBuffer

  • flushSendBuffer(): void

  • Flushes send buffer

    Returns void

getChannels

  • Returns all created channels

    Returns RealtimeChannel[]

isConnected

  • isConnected(): boolean

  • Returns true is the connection is open.

    Returns boolean

log

  • log(kind: string, msg: string, data?: any): void

  • Logs the message.

    For customized logging, this.logger can be overridden.

    Parameters

    • kind: string
    • msg: string
    • Optional data: any

    Returns void

push

  • Push out a message if the socket is connected.

    If the socket is not connected, the message gets enqueued within a local buffer, and sent out when a connection is next established.

    Parameters

    Returns void

removeAllChannels

  • Unsubscribes and removes all channels

    Returns Promise<RealtimeRemoveChannelResponse[]>

removeChannel

  • Unsubscribes and removes a single channel

    Parameters

    Returns Promise<RealtimeRemoveChannelResponse>

sendHeartbeat

  • sendHeartbeat(): Promise<void>

  • Sends a heartbeat message if the socket is connected.

    Returns Promise<void>

setAuth

  • setAuth(token?: null | string): Promise<void>

  • Sets the JWT access token used for channel subscription authorization and Realtime RLS.

    If param is null it will use the accessToken callback function or the token set on the client.

    On callback used, it will set the value of the token internal to the client.

    Parameters

    • Optional token: null | string

      A JWT string to override the token set on the client.

    Returns Promise<void>

Generated using TypeDoc