FilesExpand file tree

 pointer_bindings

/

stream.js

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

70 lines (54 loc) · 1.25 KB

 pointer_bindings

/

stream.js

Copy path

Top

File metadata and controls

• Code
• Blame

70 lines (54 loc) · 1.25 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

var events = require('events');

var util = require('util');

function Stream() {

events.EventEmitter.call(this);

}

util.inherits(Stream, events.EventEmitter);

exports.Stream = Stream;

Stream.prototype.pipe = function(dest, options) {

var source = this;

function ondata(chunk) {

if (dest.writable) {

if (false === dest.write(chunk)) source.pause();

}

}

source.on('data', ondata);

function ondrain() {

if (source.readable) source.resume();

}

dest.on('drain', ondrain);

/*

* If the 'end' option is not supplied, dest.end() will be called when

* source gets the 'end' event.

*/

if (!options || options.end !== false) {

function onend() {

dest.end();

}

source.on('end', onend);

}

dest.on('close', function() {

source.removeListener('data', ondata);

dest.removeListener('drain', ondrain);

source.removeListener('end', onend);

});

/*

* Questionable:

*/

if (!source.pause) {

source.pause = function() {

source.emit('pause');

};

}

if (!source.resume) {

source.resume = function() {

source.emit('resume');

};

}

dest.on('pause', function() {

source.pause();

});

dest.on('resume', function() {

if (source.readable) source.resume();

});

};