MCPcopy Index your code
hub / github.com/nukeop/nuclear / connect

Function connect

packages/player/src/remoteControl/useEventSource.ts:24–50  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

22 let retries = 0;
23
24 const connect = () => {
25 const eventSource = new EventSource(url);
26 source.current = eventSource;
27
28 eventSource.addEventListener('open', () => {
29 retries = 0;
30 setStatus('connected');
31 });
32
33 eventSource.addEventListener('error', () => {
34 if (eventSource.readyState === EventSource.CLOSED && !cancelled) {
35 eventSource.close();
36 source.current = null;
37 retries++;
38
39 if (retries > MAX_RETRIES) {
40 setStatus('failed');
41 return;
42 }
43
44 setStatus('reconnecting');
45 reconnectTimeout = setTimeout(connect, RECONNECT_DELAY_MS);
46 } else if (eventSource.readyState === EventSource.CONNECTING) {
47 setStatus('reconnecting');
48 }
49 });
50 };
51
52 connect();
53

Callers 1

useEventSourceFunction · 0.70

Calls 2

addEventListenerMethod · 0.80
closeMethod · 0.45

Tested by

no test coverage detected