reject promise on WebSocket initiation failure.
This commit is contained in:
parent
6b73bbf8a3
commit
5733f9c4e4
8
relay.ts
8
relay.ts
|
@ -30,7 +30,7 @@ export type Relay = {
|
||||||
on: <T extends keyof RelayEvent, U extends RelayEvent[T]>(
|
on: <T extends keyof RelayEvent, U extends RelayEvent[T]>(
|
||||||
event: T,
|
event: T,
|
||||||
listener: U
|
listener: U
|
||||||
) => void
|
) => void
|
||||||
}
|
}
|
||||||
export type Pub = {
|
export type Pub = {
|
||||||
on: (type: 'ok' | 'failed', cb: any) => void
|
on: (type: 'ok' | 'failed', cb: any) => void
|
||||||
|
@ -85,7 +85,11 @@ export function relayInit(
|
||||||
|
|
||||||
async function connectRelay(): Promise<void> {
|
async function connectRelay(): Promise<void> {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
ws = new WebSocket(url)
|
try {
|
||||||
|
ws = new WebSocket(url)
|
||||||
|
} catch (err) {
|
||||||
|
reject(err)
|
||||||
|
}
|
||||||
|
|
||||||
ws.onopen = () => {
|
ws.onopen = () => {
|
||||||
listeners.connect.forEach(cb => cb())
|
listeners.connect.forEach(cb => cb())
|
||||||
|
|
Loading…
Reference in New Issue