@@ -17,6 +17,7 @@ const path = require('path')
17
17
// const extract = require('tar-stream').extract
18
18
19
19
const testfile = fs . readFileSync ( path . join ( __dirname , '/../testfile.txt' ) )
20
+
20
21
let testfileBig
21
22
22
23
if ( isNode ) {
@@ -93,35 +94,42 @@ describe('.get', () => {
93
94
return done ( )
94
95
}
95
96
96
- apiClients . a . get ( 'Qme79tX2bViL26vNjPsF3DP1R9rMKMvnPYJiKTTKPrXJjq' , ( err , res ) => {
97
+ apiClients . a . get ( 'Qme79tX2bViL26vNjPsF3DP1R9rMKMvnPYJiKTTKPrXJjq' , ( err , files ) => {
97
98
expect ( err ) . to . not . exist
98
99
99
- // Do not blow out the memory of nodejs :)
100
- streamEqual ( res , testfileBig , ( err , equal ) => {
101
- expect ( err ) . to . not . exist
102
- expect ( equal ) . to . be . true
103
- done ( )
100
+ files . on ( 'data' , ( file ) => {
101
+ // Do not blow out the memory of nodejs :)
102
+ streamEqual ( file . content , testfileBig , ( err , equal ) => {
103
+ expect ( err ) . to . not . exist
104
+ expect ( equal ) . to . be . true
105
+ done ( )
106
+ } )
104
107
} )
105
108
} )
106
109
} )
107
110
108
111
describe ( 'promise' , ( ) => {
109
112
it ( 'get' , ( done ) => {
110
113
apiClients . a . get ( 'Qma4hjFTnCasJ8PVp3mZbZK5g2vGDT4LByLJ7m8ciyRFZP' )
111
- . then ( ( res ) => {
112
- let buf = ''
113
- res
114
- . on ( 'error' , ( err ) => {
115
- throw err
116
- } )
117
- . on ( 'data' , ( data ) => {
118
- buf += data
119
- } )
120
- . on ( 'end' , ( ) => {
121
- expect ( buf ) . to . contain ( testfile . toString ( ) )
122
- done ( )
123
- } )
114
+ . then ( ( files ) => {
115
+ files . on ( 'data' , ( file ) => {
116
+ let buf = ''
117
+ file . content
118
+ . on ( 'error' , ( err ) => {
119
+ throw err
120
+ } )
121
+ . on ( 'data' , ( data ) => {
122
+ buf += data . toString ( )
123
+ } )
124
+ . on ( 'end' , ( ) => {
125
+ expect ( buf ) . to . contain ( testfile . toString ( ) )
126
+ done ( )
127
+ } )
128
+ } )
124
129
} )
130
+ . catch ( ( err ) => {
131
+ expect ( err ) . to . not . exist
132
+ } )
125
133
} )
126
134
} )
127
135
} )
0 commit comments