FazBrowse GitHub Viewer
|
Trending
|
URL:
|
Home
Tools:
[Download Repo ZIP]
[View Raw Code]
[Original HTTPS Page]
node/lib/stream.js at https · reado/node · GitHub
reado
node
Repository navigation
Code
Pull requests
Actions
Projects
Wiki
Security and quality
Insights
Expand file tree
Breadcrumbs
node
/
lib
/
stream.js
Copy path
More file actions
More file actions
Latest commit
History
History
History
70 lines (54 loc) · 1.25 KB
Breadcrumbs
node
/
lib
/
stream.js
Copy path
File metadata and controls
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
(
)
;
}
)
;
}
;
Back
|
FazBrowse Home
|
New Git URL