Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(224)

Side by Side Diff: frog/lib/node/zlib.dart

Issue 9034014: Add support for the node net module. (Closed) Base URL: http://dart.googlecode.com/svn/branches/bleeding_edge/dart/
Patch Set: '' Created 8 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
(Empty)
1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file.
4
5 #library('zlib');
6 #import('node.dart');
7
8 // module zlib
9
10 class Zlib {
11
12 int get Z_NO_FLUSH() => _zlib.Z_NO_FLUSH;
13
14 int get Z_PARTIAL_FLUSH() => _zlib.Z_PARTIAL_FLUSH;
15 int get Z_SYNC_FLUSH() => _zlib.Z_SYNC_FLUSH;
16 int get Z_FULL_FLUSH() => _zlib.Z_FULL_FLUSH;
17 int get Z_FINISH() => _zlib.Z_FINISH;
18 int get Z_BLOCK() => _zlib.Z_BLOCK;
19
20 int get Z_OK() => _zlib.Z_OK;
21 int get Z_STREAM_END() => _zlib.Z_STREAM_END;
22 int get Z_NEED_DICT() => _zlib.Z_NEED_DICT;
23
24 int get Z_ERRNO() => _zlib.Z_ERRNO;
25 int get Z_STREAM_ERROR() => _zlib.Z_STREAM_ERROR;
26 int get Z_DATA_ERROR() => _zlib.Z_DATA_ERROR;
27 int get Z_MEM_ERROR() => _zlib.Z_MEM_ERROR;
28 int get Z_BUF_ERROR() => _zlib.Z_BUF_ERROR;
29 int get Z_VERSION_ERROR() => _zlib.Z_VERSION_ERROR;
30
31 int get Z_NO_COMPRESSION() => _zlib.Z_NO_COMPRESSION;
32 int get Z_BEST_SPEED() => _zlib.Z_BEST_SPEED;
33 int get Z_BEST_COMPRESSION() => _zlib.Z_BEST_COMPRESSION;
34 int get Z_DEFAULT_COMPRESSION() => _zlib.Z_DEFAULT_COMPRESSION;
35
36 int get Z_FILTERED() => _zlib.Z_FILTERED;
37 int get Z_HUFFMAN_ONLY() => _zlib.Z_HUFFMAN_ONLY;
38 int get Z_RLE() => _zlib.Z_RLE;
39 int get Z_FIXED() => _zlib.Z_FIXED;
40 int get Z_DEFAULT_STRATEGY() => _zlib.Z_DEFAULT_STRATEGY;
41
42 int get ZLIB_VERNUM() => _zlib.ZLIB_VERNUM;
43 String get ZLIB_VERSION() => _zlib.ZLIB_VERSION;
44
45 int get Z_MIN_WINDOWBITS() => _zlib.Z_MIN_WINDOWBITS;
46 int get Z_MAX_WINDOWBITS() => _zlib.Z_MAX_WINDOWBITS;
47 int get Z_DEFAULT_WINDOWBITS() => _zlib.Z_DEFAULT_WINDOWBITS;
48
49 int get Z_MIN_CHUNK() => _zlib.Z_MIN_CHUNK;
50 num get Z_MAX_CHUNK() => _zlib.Z_MAX_CHUNK;
51 int get Z_DEFAULT_CHUNK() => _zlib.Z_DEFAULT_CHUNK;
52
53 int get Z_MIN_MEMLEVEL() => _zlib.Z_MIN_MEMLEVEL;
54 int get Z_MAX_MEMLEVEL() => _zlib.Z_MAX_MEMLEVEL;
55 int get Z_DEFAULT_MEMLEVEL() => _zlib.Z_DEFAULT_MEMLEVEL;
56
57 int get Z_MIN_LEVEL() => _zlib.Z_MIN_LEVEL;
58 int get Z_MAX_LEVEL() => _zlib.Z_MAX_LEVEL;
59 int get Z_DEFAULT_LEVEL() => _zlib.Z_DEFAULT_LEVEL;
60
61 Gzip createGzip([Map<String,Object> options])
62 => _zlib.createGzip(options);
63 Gunzip createGunzip([Map<String,Object> options])
64 => _zlib.createGunzip(options);
65 Deflate createDeflate([Map<String,Object> options])
66 => _zlib.createDeflate(options);
67 Inflate createInflate([Map<String,Object> options])
68 => _zlib.createInflate(options);
69 DeflateRaw createDeflateRaw([Map<String,Object> options])
70 => _zlib.createDeflateRaw(options);
71 InflateRaw createInflateRaw([Map<String,Object> options])
72 => _zlib.createInflateRaw(options);
73 Unzip createUnzip([Map<String,Object> options])
74 => _zlib.createUnzip(options);
75
76 void deflate(String buf,
77 void callback(Error err, String result))
78 => _zlib.deflate(buf, callback);
79 void deflateBuffer(Buffer buf,
80 void callback(Error err, Buffer result))
81 => _zlib.deflate(buf, callback);
82
83 void deflateRaw(String buf,
84 void callback(Error err, String result))
85 => _zlib.deflateRaw(buf, callback);
86 void deflateRawBuffer(Buffer buf,
87 void callback(Error err, Buffer result))
88 => _zlib.deflateRaw(buf, callback);
89
90 void gzip(String buf,
91 void callback(Error err, String result))
92 => _zlib.gzip(buf, callback);
93 void gzipBuffer(Buffer buf,
94 void callback(Error err, Buffer result))
95 => _zlib.gzip(buf, callback);
96
97 void gunzip(String buf,
98 void callback(Error err, String result))
99 => _zlib.gunzip(buf, callback);
100 void gunzipBuffer(Buffer buf,
101 void callback(Error err, Buffer result))
102 => _zlib.gunzip(buf, callback);
103
104 void inflate(String buf,
105 void callback(Error err, String result))
106 => _zlib.inflate(buf, callback);
107 void inflateBuffer(Buffer buf,
108 void callback(Error err, Buffer result))
109 => _zlib.inflate(buf, callback);
110
111 void inflateRaw(String buf,
112 void callback(Error err, String result))
113 => _zlib.inflateRaw(buf, callback);
114 void inflateRawBuffer(Buffer buf,
115 void callback(Error err, Buffer result))
116 => _zlib.inflateRaw(buf, callback);
117
118 void unzip(String buf,
119 void callback(Error err, String result))
120 => _zlib.unzip(buf, callback);
121 void unzipBuffer(Buffer buf,
122 void callback(Error err, Buffer result))
123 => _zlib.unzip(buf, callback);
124 }
125
126 class _zlib native "require('zlib')" {
127 static int Z_NO_FLUSH;
128 static int Z_PARTIAL_FLUSH;
129 static int Z_SYNC_FLUSH;
130 static int Z_FULL_FLUSH;
131 static int Z_FINISH;
132 static int Z_BLOCK;
133
134 static int Z_OK;
135 static int Z_STREAM_END;
136 static int Z_NEED_DICT;
137
138 static int Z_ERRNO;
139 static int Z_STREAM_ERROR;
140 static int Z_DATA_ERROR;
141 static int Z_MEM_ERROR;
142 static int Z_BUF_ERROR;
143 static int Z_VERSION_ERROR;
144
145 static int Z_NO_COMPRESSION;
146 static int Z_BEST_SPEED;
147 static int Z_BEST_COMPRESSION;
148 static int Z_DEFAULT_COMPRESSION;
149
150 static int Z_FILTERED;
151 static int Z_HUFFMAN_ONLY;
152 static int Z_RLE;
153 static int Z_FIXED;
154 static int Z_DEFAULT_STRATEGY;
155
156 static int ZLIB_VERNUM;
157 static String get ZLIB_VERSION;
158
159 static int Z_MIN_WINDOWBITS;
160 static int Z_MAX_WINDOWBITS;
161 static int Z_DEFAULT_WINDOWBITS;
162
163 static int Z_MIN_CHUNK;
164 static num get Z_MAX_CHUNK;
165 static int Z_DEFAULT_CHUNK;
166
167 static int Z_MIN_MEMLEVEL;
168 static int Z_MAX_MEMLEVEL;
169 static int Z_DEFAULT_MEMLEVEL;
170
171 static int Z_MIN_LEVEL;
172 static int Z_MAX_LEVEL;
173 static int Z_DEFAULT_LEVEL;
174
175 static Gzip createGzip([Map options]) native;
176 static Gunzip createGunzip([Map options]) native;
177 static Deflate createDeflate([Map options]) native;
178 static Inflate createInflate([Map options]) native;
179 static DeflateRaw createDeflateRaw([Map options]) native;
180 static InflateRaw createInflateRaw([Map options]) native;
181 static Unzip createUnzip([Map options]) native;
182
183 static void deflate(var buf,
184 void callback(Error err, var result)) native;
185 static void deflateRaw(var buf,
186 void callback(Error err, var result)) native;
187 static void gzip(var buf,
188 void callback(Error err, var result)) native;
189 static void gunzip(var buf,
190 void callback(Error err, var result)) native;
191 static void inflate(var buf,
192 void callback(Error err, var result)) native;
193 static void inflateRaw(var buf,
194 void callback(Error err, var result)) native;
195 static void unzip(var buf,
196 void callback(Error err, var result)) native;
197 }
198
199 Zlib get zlib() => new Zlib();
200
201 class Gzip implements ReadWriteStream native "require('zlib').Gzip"{
202 // EventEmitter
203 void removeAllListeners(String event) native;
204 void setMaxListeners(num n) native;
205 var _listeners(String key)
206 native "return this.listeners(key);";
207
208 // CommonStream
209
210 // Error event
211 void emitError(Error error)
212 native "this.emit('error', error);";
213 void addListenerError(StreamErrorListener listener)
214 native "this.addListener('error', listener);";
215 void onError(StreamErrorListener listener)
216 native "this.on('error', listener);";
217 void onceError(StreamErrorListener listener)
218 native "this.once('error', listener);";
219 void removeListenerError(StreamErrorListener listener)
220 native "this.removeListener('error', listener);";
221 List<StreamErrorListener> listenersError()
222 => new _NativeListPrimitiveElement<StreamErrorListener>(
223 _listeners('error'));
224
225 // Close event
226 void emitClose()
227 native "this.emit('close');";
228 void addListenerClose(StreamCloseListener listener)
229 native "this.addListener('close', listener);";
230 void onClose(StreamCloseListener listener)
231 native "this.on('close', listener);";
232 void onceClose(StreamCloseListener listener)
233 native "this.once('close', listener);";
234 void removeListenerClose(StreamCloseListener listener)
235 native "this.removeListener('close', listener);";
236 List<StreamCloseListener> listenersClose()
237 => new _NativeListPrimitiveElement<StreamCloseListener>(
238 _listeners('close'));
239
240 // ReadableStream
241
242 // Data event
243 void emitData(var data)
244 native "this.emit('data', data);";
245 void addListenerData(ReadableStreamDataListener listener)
246 native "this.addListener('data', listener);";
247 void onData(ReadableStreamDataListener listener)
248 native "this.on('data', listener);";
249 void onceData(ReadableStreamDataListener listener)
250 native "this.once('data', listener);";
251 void removeListenerData(ReadableStreamDataListener listener)
252 native "this.removeListener('data', listener);";
253 List<ReadableStreamDataListener> listenersData()
254 => new _NativeListPrimitiveElement<ReadableStreamDataListener>(
255 _listeners('data'));
256
257 // End event
258 void emitEnd()
259 native "this.emit('end');";
260 void addListenerEnd(ReadableStreamEndListener listener)
261 native "this.addListener('end', listener);";
262 void onEnd(ReadableStreamEndListener listener)
263 native "this.on('end', listener);";
264 void onceEnd(ReadableStreamEndListener listener)
265 native "this.once('end', listener);";
266 void removeListenerEnd(ReadableStreamEndListener listener)
267 native "this.removeListener('end', listener);";
268 List<ReadableStreamEndListener> listenersEnd()
269 => new _NativeListPrimitiveElement<ReadableStreamEndListener>(
270 _listeners('end'));
271
272 bool readable;
273 void setEncoding(String encoding) native;
274 void pause() native;
275 void resume() native;
276 void destroy() native;
277 void destroySoon() native;
278 WritableStream pipe(WritableStream destination, [Map options]) native;
279
280 // WritableStream
281
282 // Drain event
283 void emitDrain()
284 native "this.emit('drain');";
285 void addListenerDrain(WritableStreamDrainListener listener)
286 native "this.addListener('drain', listener);";
287 void onDrain(WritableStreamDrainListener listener)
288 native "this.on('drain', listener);";
289 void onceDrain(WritableStreamDrainListener listener)
290 native "this.once('drain', listener);";
291 void removeListenerDrain(WritableStreamDrainListener listener)
292 native "this.removeListener('drain', listener);";
293 List<WritableStreamDrainListener> listenersDrain()
294 => new _NativeListPrimitiveElement<WritableStreamDrainListener>(
295 _listeners('drain'));
296
297 // Pipe event
298 void emitPipe(ReadableStream src)
299 native "this.emit('pipe', src);";
300 void addListenerPipe(WritableStreamPipeListener listener)
301 native "this.addListener('pipe', listener);";
302 void onPipe(WritableStreamPipeListener listener)
303 native "this.on('pipe', listener);";
304 void oncePipe(WritableStreamPipeListener listener)
305 native "this.once('pipe', listener);";
306 void removeListenerPipe(WritableStreamPipeListener listener)
307 native "this.removeListener('pipe', listener);";
308 List<WritableStreamPipeListener> listenersPipe()
309 => new _NativeListPrimitiveElement<WritableStreamPipeListener>(
310 _listeners('pipe'));
311
312 bool writable;
313 bool write(String string, [String encoding, int fd]) native;
314 bool writeBuffer(Buffer buffer) native;
315 void end([String string, String encoding]) native;
316 void endBuffer(Buffer buffer) native "this.end(buffer);";
317 }
318
319 class Gunzip implements ReadWriteStream native "require('zlib').Gunzip"{
320 // EventEmitter
321 void removeAllListeners(String event) native;
322 void setMaxListeners(num n) native;
323 var _listeners(String key)
324 native "return this.listeners(key);";
325
326 // CommonStream
327
328 // Error event
329 void emitError(Error error)
330 native "this.emit('error', error);";
331 void addListenerError(StreamErrorListener listener)
332 native "this.addListener('error', listener);";
333 void onError(StreamErrorListener listener)
334 native "this.on('error', listener);";
335 void onceError(StreamErrorListener listener)
336 native "this.once('error', listener);";
337 void removeListenerError(StreamErrorListener listener)
338 native "this.removeListener('error', listener);";
339 List<StreamErrorListener> listenersError()
340 => new _NativeListPrimitiveElement<StreamErrorListener>(
341 _listeners('error'));
342
343 // Close event
344 void emitClose()
345 native "this.emit('close');";
346 void addListenerClose(StreamCloseListener listener)
347 native "this.addListener('close', listener);";
348 void onClose(StreamCloseListener listener)
349 native "this.on('close', listener);";
350 void onceClose(StreamCloseListener listener)
351 native "this.once('close', listener);";
352 void removeListenerClose(StreamCloseListener listener)
353 native "this.removeListener('close', listener);";
354 List<StreamCloseListener> listenersClose()
355 => new _NativeListPrimitiveElement<StreamCloseListener>(
356 _listeners('close'));
357
358 // ReadableStream
359
360 // Data event
361 void emitData(var data)
362 native "this.emit('data', data);";
363 void addListenerData(ReadableStreamDataListener listener)
364 native "this.addListener('data', listener);";
365 void onData(ReadableStreamDataListener listener)
366 native "this.on('data', listener);";
367 void onceData(ReadableStreamDataListener listener)
368 native "this.once('data', listener);";
369 void removeListenerData(ReadableStreamDataListener listener)
370 native "this.removeListener('data', listener);";
371 List<ReadableStreamDataListener> listenersData()
372 => new _NativeListPrimitiveElement<ReadableStreamDataListener>(
373 _listeners('data'));
374
375 // End event
376 void emitEnd()
377 native "this.emit('end');";
378 void addListenerEnd(ReadableStreamEndListener listener)
379 native "this.addListener('end', listener);";
380 void onEnd(ReadableStreamEndListener listener)
381 native "this.on('end', listener);";
382 void onceEnd(ReadableStreamEndListener listener)
383 native "this.once('end', listener);";
384 void removeListenerEnd(ReadableStreamEndListener listener)
385 native "this.removeListener('end', listener);";
386 List<ReadableStreamEndListener> listenersEnd()
387 => new _NativeListPrimitiveElement<ReadableStreamEndListener>(
388 _listeners('end'));
389
390 bool readable;
391 void setEncoding(String encoding) native;
392 void pause() native;
393 void resume() native;
394 void destroy() native;
395 void destroySoon() native;
396 WritableStream pipe(WritableStream destination, [Map options]) native;
397
398 // WritableStream
399
400 // Drain event
401 void emitDrain()
402 native "this.emit('drain');";
403 void addListenerDrain(WritableStreamDrainListener listener)
404 native "this.addListener('drain', listener);";
405 void onDrain(WritableStreamDrainListener listener)
406 native "this.on('drain', listener);";
407 void onceDrain(WritableStreamDrainListener listener)
408 native "this.once('drain', listener);";
409 void removeListenerDrain(WritableStreamDrainListener listener)
410 native "this.removeListener('drain', listener);";
411 List<WritableStreamDrainListener> listenersDrain()
412 => new _NativeListPrimitiveElement<WritableStreamDrainListener>(
413 _listeners('drain'));
414
415 // Pipe event
416 void emitPipe(ReadableStream src)
417 native "this.emit('pipe', src);";
418 void addListenerPipe(WritableStreamPipeListener listener)
419 native "this.addListener('pipe', listener);";
420 void onPipe(WritableStreamPipeListener listener)
421 native "this.on('pipe', listener);";
422 void oncePipe(WritableStreamPipeListener listener)
423 native "this.once('pipe', listener);";
424 void removeListenerPipe(WritableStreamPipeListener listener)
425 native "this.removeListener('pipe', listener);";
426 List<WritableStreamPipeListener> listenersPipe()
427 => new _NativeListPrimitiveElement<WritableStreamPipeListener>(
428 _listeners('pipe'));
429
430 bool writable;
431 bool write(String string, [String encoding, int fd]) native;
432 bool writeBuffer(Buffer buffer) native;
433 void end([String string, String encoding]) native;
434 void endBuffer(Buffer buffer) native "this.end(buffer);";
435 }
436
437 class Deflate implements ReadWriteStream native "require('zlib').Deflate"{
438 // EventEmitter
439 void removeAllListeners(String event) native;
440 void setMaxListeners(num n) native;
441 var _listeners(String key)
442 native "return this.listeners(key);";
443
444 // CommonStream
445
446 // Error event
447 void emitError(Error error)
448 native "this.emit('error', error);";
449 void addListenerError(StreamErrorListener listener)
450 native "this.addListener('error', listener);";
451 void onError(StreamErrorListener listener)
452 native "this.on('error', listener);";
453 void onceError(StreamErrorListener listener)
454 native "this.once('error', listener);";
455 void removeListenerError(StreamErrorListener listener)
456 native "this.removeListener('error', listener);";
457 List<StreamErrorListener> listenersError()
458 => new _NativeListPrimitiveElement<StreamErrorListener>(
459 _listeners('error'));
460
461 // Close event
462 void emitClose()
463 native "this.emit('close');";
464 void addListenerClose(StreamCloseListener listener)
465 native "this.addListener('close', listener);";
466 void onClose(StreamCloseListener listener)
467 native "this.on('close', listener);";
468 void onceClose(StreamCloseListener listener)
469 native "this.once('close', listener);";
470 void removeListenerClose(StreamCloseListener listener)
471 native "this.removeListener('close', listener);";
472 List<StreamCloseListener> listenersClose()
473 => new _NativeListPrimitiveElement<StreamCloseListener>(
474 _listeners('close'));
475
476 // ReadableStream
477
478 // Data event
479 void emitData(var data)
480 native "this.emit('data', data);";
481 void addListenerData(ReadableStreamDataListener listener)
482 native "this.addListener('data', listener);";
483 void onData(ReadableStreamDataListener listener)
484 native "this.on('data', listener);";
485 void onceData(ReadableStreamDataListener listener)
486 native "this.once('data', listener);";
487 void removeListenerData(ReadableStreamDataListener listener)
488 native "this.removeListener('data', listener);";
489 List<ReadableStreamDataListener> listenersData()
490 => new _NativeListPrimitiveElement<ReadableStreamDataListener>(
491 _listeners('data'));
492
493 // End event
494 void emitEnd()
495 native "this.emit('end');";
496 void addListenerEnd(ReadableStreamEndListener listener)
497 native "this.addListener('end', listener);";
498 void onEnd(ReadableStreamEndListener listener)
499 native "this.on('end', listener);";
500 void onceEnd(ReadableStreamEndListener listener)
501 native "this.once('end', listener);";
502 void removeListenerEnd(ReadableStreamEndListener listener)
503 native "this.removeListener('end', listener);";
504 List<ReadableStreamEndListener> listenersEnd()
505 => new _NativeListPrimitiveElement<ReadableStreamEndListener>(
506 _listeners('end'));
507
508 bool readable;
509 void setEncoding(String encoding) native;
510 void pause() native;
511 void resume() native;
512 void destroy() native;
513 void destroySoon() native;
514 WritableStream pipe(WritableStream destination, [Map options]) native;
515
516 // WritableStream
517
518 // Drain event
519 void emitDrain()
520 native "this.emit('drain');";
521 void addListenerDrain(WritableStreamDrainListener listener)
522 native "this.addListener('drain', listener);";
523 void onDrain(WritableStreamDrainListener listener)
524 native "this.on('drain', listener);";
525 void onceDrain(WritableStreamDrainListener listener)
526 native "this.once('drain', listener);";
527 void removeListenerDrain(WritableStreamDrainListener listener)
528 native "this.removeListener('drain', listener);";
529 List<WritableStreamDrainListener> listenersDrain()
530 => new _NativeListPrimitiveElement<WritableStreamDrainListener>(
531 _listeners('drain'));
532
533 // Pipe event
534 void emitPipe(ReadableStream src)
535 native "this.emit('pipe', src);";
536 void addListenerPipe(WritableStreamPipeListener listener)
537 native "this.addListener('pipe', listener);";
538 void onPipe(WritableStreamPipeListener listener)
539 native "this.on('pipe', listener);";
540 void oncePipe(WritableStreamPipeListener listener)
541 native "this.once('pipe', listener);";
542 void removeListenerPipe(WritableStreamPipeListener listener)
543 native "this.removeListener('pipe', listener);";
544 List<WritableStreamPipeListener> listenersPipe()
545 => new _NativeListPrimitiveElement<WritableStreamPipeListener>(
546 _listeners('pipe'));
547
548 bool writable;
549 bool write(String string, [String encoding, int fd]) native;
550 bool writeBuffer(Buffer buffer) native;
551 void end([String string, String encoding]) native;
552 void endBuffer(Buffer buffer) native "this.end(buffer);";
553 }
554
555 class Inflate implements ReadWriteStream native "require('zlib').Inflate"{
556 // EventEmitter
557 void removeAllListeners(String event) native;
558 void setMaxListeners(num n) native;
559 var _listeners(String key)
560 native "return this.listeners(key);";
561
562 // CommonStream
563
564 // Error event
565 void emitError(Error error)
566 native "this.emit('error', error);";
567 void addListenerError(StreamErrorListener listener)
568 native "this.addListener('error', listener);";
569 void onError(StreamErrorListener listener)
570 native "this.on('error', listener);";
571 void onceError(StreamErrorListener listener)
572 native "this.once('error', listener);";
573 void removeListenerError(StreamErrorListener listener)
574 native "this.removeListener('error', listener);";
575 List<StreamErrorListener> listenersError()
576 => new _NativeListPrimitiveElement<StreamErrorListener>(
577 _listeners('error'));
578
579 // Close event
580 void emitClose()
581 native "this.emit('close');";
582 void addListenerClose(StreamCloseListener listener)
583 native "this.addListener('close', listener);";
584 void onClose(StreamCloseListener listener)
585 native "this.on('close', listener);";
586 void onceClose(StreamCloseListener listener)
587 native "this.once('close', listener);";
588 void removeListenerClose(StreamCloseListener listener)
589 native "this.removeListener('close', listener);";
590 List<StreamCloseListener> listenersClose()
591 => new _NativeListPrimitiveElement<StreamCloseListener>(
592 _listeners('close'));
593
594 // ReadableStream
595
596 // Data event
597 void emitData(var data)
598 native "this.emit('data', data);";
599 void addListenerData(ReadableStreamDataListener listener)
600 native "this.addListener('data', listener);";
601 void onData(ReadableStreamDataListener listener)
602 native "this.on('data', listener);";
603 void onceData(ReadableStreamDataListener listener)
604 native "this.once('data', listener);";
605 void removeListenerData(ReadableStreamDataListener listener)
606 native "this.removeListener('data', listener);";
607 List<ReadableStreamDataListener> listenersData()
608 => new _NativeListPrimitiveElement<ReadableStreamDataListener>(
609 _listeners('data'));
610
611 // End event
612 void emitEnd()
613 native "this.emit('end');";
614 void addListenerEnd(ReadableStreamEndListener listener)
615 native "this.addListener('end', listener);";
616 void onEnd(ReadableStreamEndListener listener)
617 native "this.on('end', listener);";
618 void onceEnd(ReadableStreamEndListener listener)
619 native "this.once('end', listener);";
620 void removeListenerEnd(ReadableStreamEndListener listener)
621 native "this.removeListener('end', listener);";
622 List<ReadableStreamEndListener> listenersEnd()
623 => new _NativeListPrimitiveElement<ReadableStreamEndListener>(
624 _listeners('end'));
625
626 bool readable;
627 void setEncoding(String encoding) native;
628 void pause() native;
629 void resume() native;
630 void destroy() native;
631 void destroySoon() native;
632 WritableStream pipe(WritableStream destination, [Map options]) native;
633
634 // WritableStream
635
636 // Drain event
637 void emitDrain()
638 native "this.emit('drain');";
639 void addListenerDrain(WritableStreamDrainListener listener)
640 native "this.addListener('drain', listener);";
641 void onDrain(WritableStreamDrainListener listener)
642 native "this.on('drain', listener);";
643 void onceDrain(WritableStreamDrainListener listener)
644 native "this.once('drain', listener);";
645 void removeListenerDrain(WritableStreamDrainListener listener)
646 native "this.removeListener('drain', listener);";
647 List<WritableStreamDrainListener> listenersDrain()
648 => new _NativeListPrimitiveElement<WritableStreamDrainListener>(
649 _listeners('drain'));
650
651 // Pipe event
652 void emitPipe(ReadableStream src)
653 native "this.emit('pipe', src);";
654 void addListenerPipe(WritableStreamPipeListener listener)
655 native "this.addListener('pipe', listener);";
656 void onPipe(WritableStreamPipeListener listener)
657 native "this.on('pipe', listener);";
658 void oncePipe(WritableStreamPipeListener listener)
659 native "this.once('pipe', listener);";
660 void removeListenerPipe(WritableStreamPipeListener listener)
661 native "this.removeListener('pipe', listener);";
662 List<WritableStreamPipeListener> listenersPipe()
663 => new _NativeListPrimitiveElement<WritableStreamPipeListener>(
664 _listeners('pipe'));
665
666 bool writable;
667 bool write(String string, [String encoding, int fd]) native;
668 bool writeBuffer(Buffer buffer) native;
669 void end([String string, String encoding]) native;
670 void endBuffer(Buffer buffer) native "this.end(buffer);";
671 }
672
673 class DeflateRaw implements ReadWriteStream
674 native "require('zlib').DeflateRaw"{
675 // EventEmitter
676 void removeAllListeners(String event) native;
677 void setMaxListeners(num n) native;
678 var _listeners(String key)
679 native "return this.listeners(key);";
680
681 // CommonStream
682
683 // Error event
684 void emitError(Error error)
685 native "this.emit('error', error);";
686 void addListenerError(StreamErrorListener listener)
687 native "this.addListener('error', listener);";
688 void onError(StreamErrorListener listener)
689 native "this.on('error', listener);";
690 void onceError(StreamErrorListener listener)
691 native "this.once('error', listener);";
692 void removeListenerError(StreamErrorListener listener)
693 native "this.removeListener('error', listener);";
694 List<StreamErrorListener> listenersError()
695 => new _NativeListPrimitiveElement<StreamErrorListener>(
696 _listeners('error'));
697
698 // Close event
699 void emitClose()
700 native "this.emit('close');";
701 void addListenerClose(StreamCloseListener listener)
702 native "this.addListener('close', listener);";
703 void onClose(StreamCloseListener listener)
704 native "this.on('close', listener);";
705 void onceClose(StreamCloseListener listener)
706 native "this.once('close', listener);";
707 void removeListenerClose(StreamCloseListener listener)
708 native "this.removeListener('close', listener);";
709 List<StreamCloseListener> listenersClose()
710 => new _NativeListPrimitiveElement<StreamCloseListener>(
711 _listeners('close'));
712
713 // ReadableStream
714
715 // Data event
716 void emitData(var data)
717 native "this.emit('data', data);";
718 void addListenerData(ReadableStreamDataListener listener)
719 native "this.addListener('data', listener);";
720 void onData(ReadableStreamDataListener listener)
721 native "this.on('data', listener);";
722 void onceData(ReadableStreamDataListener listener)
723 native "this.once('data', listener);";
724 void removeListenerData(ReadableStreamDataListener listener)
725 native "this.removeListener('data', listener);";
726 List<ReadableStreamDataListener> listenersData()
727 => new _NativeListPrimitiveElement<ReadableStreamDataListener>(
728 _listeners('data'));
729
730 // End event
731 void emitEnd()
732 native "this.emit('end');";
733 void addListenerEnd(ReadableStreamEndListener listener)
734 native "this.addListener('end', listener);";
735 void onEnd(ReadableStreamEndListener listener)
736 native "this.on('end', listener);";
737 void onceEnd(ReadableStreamEndListener listener)
738 native "this.once('end', listener);";
739 void removeListenerEnd(ReadableStreamEndListener listener)
740 native "this.removeListener('end', listener);";
741 List<ReadableStreamEndListener> listenersEnd()
742 => new _NativeListPrimitiveElement<ReadableStreamEndListener>(
743 _listeners('end'));
744
745 bool readable;
746 void setEncoding(String encoding) native;
747 void pause() native;
748 void resume() native;
749 void destroy() native;
750 void destroySoon() native;
751 WritableStream pipe(WritableStream destination, [Map options]) native;
752
753 // WritableStream
754
755 // Drain event
756 void emitDrain()
757 native "this.emit('drain');";
758 void addListenerDrain(WritableStreamDrainListener listener)
759 native "this.addListener('drain', listener);";
760 void onDrain(WritableStreamDrainListener listener)
761 native "this.on('drain', listener);";
762 void onceDrain(WritableStreamDrainListener listener)
763 native "this.once('drain', listener);";
764 void removeListenerDrain(WritableStreamDrainListener listener)
765 native "this.removeListener('drain', listener);";
766 List<WritableStreamDrainListener> listenersDrain()
767 => new _NativeListPrimitiveElement<WritableStreamDrainListener>(
768 _listeners('drain'));
769
770 // Pipe event
771 void emitPipe(ReadableStream src)
772 native "this.emit('pipe', src);";
773 void addListenerPipe(WritableStreamPipeListener listener)
774 native "this.addListener('pipe', listener);";
775 void onPipe(WritableStreamPipeListener listener)
776 native "this.on('pipe', listener);";
777 void oncePipe(WritableStreamPipeListener listener)
778 native "this.once('pipe', listener);";
779 void removeListenerPipe(WritableStreamPipeListener listener)
780 native "this.removeListener('pipe', listener);";
781 List<WritableStreamPipeListener> listenersPipe()
782 => new _NativeListPrimitiveElement<WritableStreamPipeListener>(
783 _listeners('pipe'));
784
785 bool writable;
786 bool write(String string, [String encoding, int fd]) native;
787 bool writeBuffer(Buffer buffer) native;
788 void end([String string, String encoding]) native;
789 void endBuffer(Buffer buffer) native "this.end(buffer);";
790 }
791
792 class InflateRaw implements ReadWriteStream
793 native "require('zlib').InflateRaw"{
794 // EventEmitter
795 void removeAllListeners(String event) native;
796 void setMaxListeners(num n) native;
797 var _listeners(String key)
798 native "return this.listeners(key);";
799
800 // CommonStream
801
802 // Error event
803 void emitError(Error error)
804 native "this.emit('error', error);";
805 void addListenerError(StreamErrorListener listener)
806 native "this.addListener('error', listener);";
807 void onError(StreamErrorListener listener)
808 native "this.on('error', listener);";
809 void onceError(StreamErrorListener listener)
810 native "this.once('error', listener);";
811 void removeListenerError(StreamErrorListener listener)
812 native "this.removeListener('error', listener);";
813 List<StreamErrorListener> listenersError()
814 => new _NativeListPrimitiveElement<StreamErrorListener>(
815 _listeners('error'));
816
817 // Close event
818 void emitClose()
819 native "this.emit('close');";
820 void addListenerClose(StreamCloseListener listener)
821 native "this.addListener('close', listener);";
822 void onClose(StreamCloseListener listener)
823 native "this.on('close', listener);";
824 void onceClose(StreamCloseListener listener)
825 native "this.once('close', listener);";
826 void removeListenerClose(StreamCloseListener listener)
827 native "this.removeListener('close', listener);";
828 List<StreamCloseListener> listenersClose()
829 => new _NativeListPrimitiveElement<StreamCloseListener>(
830 _listeners('close'));
831
832 // ReadableStream
833
834 // Data event
835 void emitData(var data)
836 native "this.emit('data', data);";
837 void addListenerData(ReadableStreamDataListener listener)
838 native "this.addListener('data', listener);";
839 void onData(ReadableStreamDataListener listener)
840 native "this.on('data', listener);";
841 void onceData(ReadableStreamDataListener listener)
842 native "this.once('data', listener);";
843 void removeListenerData(ReadableStreamDataListener listener)
844 native "this.removeListener('data', listener);";
845 List<ReadableStreamDataListener> listenersData()
846 => new _NativeListPrimitiveElement<ReadableStreamDataListener>(
847 _listeners('data'));
848
849 // End event
850 void emitEnd()
851 native "this.emit('end');";
852 void addListenerEnd(ReadableStreamEndListener listener)
853 native "this.addListener('end', listener);";
854 void onEnd(ReadableStreamEndListener listener)
855 native "this.on('end', listener);";
856 void onceEnd(ReadableStreamEndListener listener)
857 native "this.once('end', listener);";
858 void removeListenerEnd(ReadableStreamEndListener listener)
859 native "this.removeListener('end', listener);";
860 List<ReadableStreamEndListener> listenersEnd()
861 => new _NativeListPrimitiveElement<ReadableStreamEndListener>(
862 _listeners('end'));
863
864 bool readable;
865 void setEncoding(String encoding) native;
866 void pause() native;
867 void resume() native;
868 void destroy() native;
869 void destroySoon() native;
870 WritableStream pipe(WritableStream destination, [Map options]) native;
871
872 // WritableStream
873
874 // Drain event
875 void emitDrain()
876 native "this.emit('drain');";
877 void addListenerDrain(WritableStreamDrainListener listener)
878 native "this.addListener('drain', listener);";
879 void onDrain(WritableStreamDrainListener listener)
880 native "this.on('drain', listener);";
881 void onceDrain(WritableStreamDrainListener listener)
882 native "this.once('drain', listener);";
883 void removeListenerDrain(WritableStreamDrainListener listener)
884 native "this.removeListener('drain', listener);";
885 List<WritableStreamDrainListener> listenersDrain()
886 => new _NativeListPrimitiveElement<WritableStreamDrainListener>(
887 _listeners('drain'));
888
889 // Pipe event
890 void emitPipe(ReadableStream src)
891 native "this.emit('pipe', src);";
892 void addListenerPipe(WritableStreamPipeListener listener)
893 native "this.addListener('pipe', listener);";
894 void onPipe(WritableStreamPipeListener listener)
895 native "this.on('pipe', listener);";
896 void oncePipe(WritableStreamPipeListener listener)
897 native "this.once('pipe', listener);";
898 void removeListenerPipe(WritableStreamPipeListener listener)
899 native "this.removeListener('pipe', listener);";
900 List<WritableStreamPipeListener> listenersPipe()
901 => new _NativeListPrimitiveElement<WritableStreamPipeListener>(
902 _listeners('pipe'));
903
904 bool writable;
905 bool write(String string, [String encoding, int fd]) native;
906 bool writeBuffer(Buffer buffer) native;
907 void end([String string, String encoding]) native;
908 void endBuffer(Buffer buffer) native "this.end(buffer);";
909 }
910
911 class Unzip implements ReadWriteStream native "require('zlib').Unzip"{
912 // EventEmitter
913 void removeAllListeners(String event) native;
914 void setMaxListeners(num n) native;
915 var _listeners(String key)
916 native "return this.listeners(key);";
917
918 // CommonStream
919
920 // Error event
921 void emitError(Error error)
922 native "this.emit('error', error);";
923 void addListenerError(StreamErrorListener listener)
924 native "this.addListener('error', listener);";
925 void onError(StreamErrorListener listener)
926 native "this.on('error', listener);";
927 void onceError(StreamErrorListener listener)
928 native "this.once('error', listener);";
929 void removeListenerError(StreamErrorListener listener)
930 native "this.removeListener('error', listener);";
931 List<StreamErrorListener> listenersError()
932 => new _NativeListPrimitiveElement<StreamErrorListener>(
933 _listeners('error'));
934
935 // Close event
936 void emitClose()
937 native "this.emit('close');";
938 void addListenerClose(StreamCloseListener listener)
939 native "this.addListener('close', listener);";
940 void onClose(StreamCloseListener listener)
941 native "this.on('close', listener);";
942 void onceClose(StreamCloseListener listener)
943 native "this.once('close', listener);";
944 void removeListenerClose(StreamCloseListener listener)
945 native "this.removeListener('close', listener);";
946 List<StreamCloseListener> listenersClose()
947 => new _NativeListPrimitiveElement<StreamCloseListener>(
948 _listeners('close'));
949
950 // ReadableStream
951
952 // Data event
953 void emitData(var data)
954 native "this.emit('data', data);";
955 void addListenerData(ReadableStreamDataListener listener)
956 native "this.addListener('data', listener);";
957 void onData(ReadableStreamDataListener listener)
958 native "this.on('data', listener);";
959 void onceData(ReadableStreamDataListener listener)
960 native "this.once('data', listener);";
961 void removeListenerData(ReadableStreamDataListener listener)
962 native "this.removeListener('data', listener);";
963 List<ReadableStreamDataListener> listenersData()
964 => new _NativeListPrimitiveElement<ReadableStreamDataListener>(
965 _listeners('data'));
966
967 // End event
968 void emitEnd()
969 native "this.emit('end');";
970 void addListenerEnd(ReadableStreamEndListener listener)
971 native "this.addListener('end', listener);";
972 void onEnd(ReadableStreamEndListener listener)
973 native "this.on('end', listener);";
974 void onceEnd(ReadableStreamEndListener listener)
975 native "this.once('end', listener);";
976 void removeListenerEnd(ReadableStreamEndListener listener)
977 native "this.removeListener('end', listener);";
978 List<ReadableStreamEndListener> listenersEnd()
979 => new _NativeListPrimitiveElement<ReadableStreamEndListener>(
980 _listeners('end'));
981
982 bool readable;
983 void setEncoding(String encoding) native;
984 void pause() native;
985 void resume() native;
986 void destroy() native;
987 void destroySoon() native;
988 WritableStream pipe(WritableStream destination, [Map options]) native;
989
990 // WritableStream
991
992 // Drain event
993 void emitDrain()
994 native "this.emit('drain');";
995 void addListenerDrain(WritableStreamDrainListener listener)
996 native "this.addListener('drain', listener);";
997 void onDrain(WritableStreamDrainListener listener)
998 native "this.on('drain', listener);";
999 void onceDrain(WritableStreamDrainListener listener)
1000 native "this.once('drain', listener);";
1001 void removeListenerDrain(WritableStreamDrainListener listener)
1002 native "this.removeListener('drain', listener);";
1003 List<WritableStreamDrainListener> listenersDrain()
1004 => new _NativeListPrimitiveElement<WritableStreamDrainListener>(
1005 _listeners('drain'));
1006
1007 // Pipe event
1008 void emitPipe(ReadableStream src)
1009 native "this.emit('pipe', src);";
1010 void addListenerPipe(WritableStreamPipeListener listener)
1011 native "this.addListener('pipe', listener);";
1012 void onPipe(WritableStreamPipeListener listener)
1013 native "this.on('pipe', listener);";
1014 void oncePipe(WritableStreamPipeListener listener)
1015 native "this.once('pipe', listener);";
1016 void removeListenerPipe(WritableStreamPipeListener listener)
1017 native "this.removeListener('pipe', listener);";
1018 List<WritableStreamPipeListener> listenersPipe()
1019 => new _NativeListPrimitiveElement<WritableStreamPipeListener>(
1020 _listeners('pipe'));
1021
1022 bool writable;
1023 bool write(String string, [String encoding, int fd]) native;
1024 bool writeBuffer(Buffer buffer) native;
1025 void end([String string, String encoding]) native;
1026 void endBuffer(Buffer buffer) native "this.end(buffer);";
1027 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698