Lines Matching refs:port
107 constructor(port) {
109 port,
113 port.onmessage = ({ data }) => {
129 port.close();
133 port.close();
138 port.onmessageerror = () => {
142 port.postMessage({ type: 'error', value: error });
146 port.close();
155 this[kState].port.postMessage({ type: 'pull' });
160 this[kState].port.postMessage({ type: 'error', value: reason });
166 this[kState].port.postMessage({ type: 'error', value: error });
169 this[kState].port.close();
175 constructor(port) {
177 port,
182 port.onmessage = ({ data }) => {
205 port.onmessageerror = () => {
209 port.postMessage({ type: 'error', value: error });
213 port.close();
233 this[kState].port.postMessage({ type: 'chunk', value: chunk });
239 this[kState].port.postMessage({ type: 'error', value: error });
240 this[kState].port.close();
246 this[kState].port.postMessage({ type: 'close' });
247 this[kState].port.close();
252 this[kState].port.postMessage({ type: 'error', value: reason });
258 this[kState].port.postMessage({ type: 'error', value: error });
261 this[kState].port.close();
266 function newCrossRealmReadableStream(writable, port) {
269 new CrossRealmTransformReadableSource(port));
282 function newCrossRealmWritableSink(readable, port) {
285 new CrossRealmTransformWritableSink(port));