Home
last modified time | relevance | path

Searched refs:socket (Results 1 – 25 of 57) sorted by relevance

123

/expo/apps/bare-expo/relapse/
H A Dclient.js6 let socket; variable
14 if (socket) {
16 return () => socket.close();
19 socket = new WebSocket('ws://127.0.0.1:8085');
20 socket.onopen = () => resolve();
22 socket.onmessage = ({ data }) => {
32 return () => socket.close();
36 if (!socket) {
46 socket.send(json);
/expo/packages/@expo/cli/src/run/ios/appleDevice/client/__tests__/
H A DAFCClient-test.ts13 const socket = mockSocket(); constant
14 const client = new AFCClient(socket);
33 const socket = mockSocket(); constant
34 const client = new AFCClient(socket);
55 const socket = mockSocket(); constant
56 const client = new AFCClient(socket);
82 const socket = mockSocket(); constant
83 const client = new AFCClient(socket);
102 const socket = mockSocket(); constant
103 const client = new AFCClient(socket);
[all …]
H A DUsbmuxdClient-test.ts11 const socket = mockSocket(); constant
12 const client = new UsbmuxdClient(socket);
23 ).resolves.toEqual(socket);
33 const socket = mockSocket(); constant
34 const client = new UsbmuxdClient(socket);
/expo/packages/@expo/cli/src/run/ios/appleDevice/client/
H A DDebugserverClient.ts18 constructor(public socket: Socket) { property in DebugserverClient
19 super(socket, new GDBProtocolClient(socket));
46 return this.protocolClient.socket.write('\u0003');
54 this.protocolClient.socket.write('+');
80 this.protocolClient.socket.write('+');
H A DMobileImageMounterClient.ts45 constructor(socket: Socket) {
46 super(socket, new LockdownProtocolClient(socket));
78 imageStream.pipe(this.protocolClient.socket, { end: false });
H A DLockdowndClient.ts99 constructor(public socket: Socket) { property in LockdowndClient
100 super(socket, new LockdownProtocolClient(socket));
129 this.protocolClient.socket = new tls.TLSSocket(this.protocolClient.socket, {
H A DUsbmuxdClient.ts109 constructor(public socket: Socket) { property in UsbmuxdClient
110 super(socket, new UsbmuxProtocolClient(socket));
136 return this.protocolClient.socket;
/expo/packages/@expo/cli/src/start/server/metro/inspector-proxy/
H A Ddevice.ts56 this._debuggerConnection?.socket.close();
64 oldDebugger.socket.removeAllListeners();
66 newDevice.handleDebuggerConnection(oldDebugger.socket, oldDebugger.pageId);
75 handleDebuggerConnectionWithType(socket: WS, pageId: string, debuggerType: DebuggerType): void {
76 this.handleDebuggerConnection(socket, pageId);
94 socket: WS
101 return super._interceptMessageFromDebugger(request, info, socket);
H A Dproxy.ts79 wss.on('connection', (socket, request) => {
91 socket,
106 socket.on('close', () => {
127 socket.close(WS_GENERIC_ERROR_STATUS, message || 'Unknown error');
141 wss.on('connection', (socket, request) => {
160 device.handleDebuggerConnectionWithType(socket, pageId, debuggerType);
162 device.handleDebuggerConnection(socket, pageId);
165 socket.on('close', () => {
181 socket.close(WS_GENERIC_ERROR_STATUS, message || 'Unknown error');
/expo/packages/@expo/cli/src/run/ios/appleDevice/
H A DClientManager.ts28 this.connections = [lockdowndClient.socket];
43 this.connections.push(usbmuxClient.socket);
51 this.connections.push(lockdownClient.socket);
116 tlsOptions.socket = proxy;
133 tlsOptions.socket = usbmuxdSocket;
138 this.connections.push(client.socket);
143 for (const socket of this.connections) { constant
146 socket.end();
H A DAppleDevice.ts38 client.socket.end();
42 const socket = await new UsbmuxdClient(UsbmuxdClient.connectUsbmuxdSocket()).connect( constant
46 const deviceValues = await new LockdowndClient(socket).getAllValues();
47 socket.end();
212 debugServerClient.socket.end();
/expo/packages/@expo/cli/src/run/ios/appleDevice/protocol/
H A DUsbmuxProtocol.ts26 constructor(socket: Socket) {
27 super(socket, new ProtocolReaderFactory(UsbmuxProtocolReader), new UsbmuxProtocolWriter());
50 write(socket: Socket, msg: UsbmuxMessage) {
72 socket.write(header);
73 socket.write(plistMessage);
H A DAbstractProtocol.ts113 public socket: Socket, property in ProtocolClient
146 this.socket.removeListener('data', reader.onData);
147 this.socket.removeListener('error', onError);
153 this.socket.removeListener('data', reader.onData);
154 this.socket.removeListener('error', onError);
158 this.socket.on('data', reader.onData);
159 this.socket.on('error', onError);
160 this.writer.write(this.socket, msg);
H A DLockdownProtocol.ts56 constructor(socket: Socket) {
57 super(socket, new ProtocolReaderFactory(LockdownProtocolReader), new LockdownProtocolWriter());
94 write(socket: Socket, plistData: any) {
99 socket.write(header);
100 socket.write(plistMessage);
H A DAFCProtocol.ts361 constructor(socket: Socket) {
362 super(socket, new ProtocolReaderFactory(AFCProtocolReader), new AFCProtocolWriter());
373 socket.on('data', reader.onData);
390 this.writer.write(this.socket, { ...msg, requestId });
446 write(socket: Socket, msg: AFCMessage & { requestId: number }) {
459 socket.write(header);
460 socket.write(data);
475 socket.write(payload);
H A DGDBProtocol.ts29 constructor(socket: Socket) {
30 super(socket, new ProtocolReaderFactory(GDBProtocolReader), new GDBProtocolWriter());
110 write(socket: Socket, msg: GDBMessage) {
120 socket.write(formattedCmd);
/expo/packages/@expo/cli/ts-declarations/metro-inspector-proxy/
H A Dindex.d.ts34 socket: WS;
134 constructor(id: number, name: string, app: string, socket: WS, projectRoot: string);
145 handleDebuggerConnection(socket: WS, pageId: string): void;
173 socket: WS
/expo/packages/@expo/cli/src/start/server/metro/inspector-proxy/handlers/
H A DPageReload.ts10 onDebuggerMessage(message: DebuggerRequest<PageReload>, { socket }: ExpoDebuggerInfo) {
13 socket.send(JSON.stringify({ id: message.id }));
H A DVscodeDebuggerGetPossibleBreakpoints.ts13 { socket, debuggerType }: ExpoDebuggerInfo
20 socket.send(JSON.stringify(response));
/expo/packages/@expo/cli/src/start/server/middleware/inspector/
H A DcreateJsInspectorMiddleware.ts61 req.socket instanceof TLSSocket && req.socket.encrypted === true ? 'https' : 'http';
62 const { localAddress, localPort } = req.socket;
/expo/ios/versioned-react-native/ABI47_0_0/ReactNative/React/DevSupport/
H A DABI47_0_0RCTPackagerClient.h39 - (instancetype)initWithId:(id)msgId socket:(ABI47_0_0RCTReconnectingWebSocket *)socket;
/expo/ios/versioned-react-native/ABI49_0_0/ReactNative/React/DevSupport/
H A DABI49_0_0RCTPackagerClient.h39 - (instancetype)initWithId:(id)msgId socket:(ABI49_0_0RCTReconnectingWebSocket *)socket;
/expo/ios/versioned-react-native/ABI48_0_0/ReactNative/React/DevSupport/
H A DABI48_0_0RCTPackagerClient.h39 - (instancetype)initWithId:(id)msgId socket:(ABI48_0_0RCTReconnectingWebSocket *)socket;
/expo/packages/@expo/cli/src/start/server/metro/inspector-proxy/handlers/__tests__/
H A DNetworkResponse.test.ts27 { socket: debuggerSocket }
55 { socket: debuggerSocket }
H A DVscodeDebuggerGetPossibleBreakpoints.test.ts27 socket: { send: jest.fn() },
41 expect(debuggerInfo.socket.send).toBeCalledWith(

123