|
1 | 1 | 'use strict'
|
2 | 2 |
|
| 3 | +const Minipass = require('minipass') |
3 | 4 | const test = require('tap').test
|
4 | 5 | const tnock = require('./fixtures/tnock.js')
|
5 | 6 |
|
@@ -94,27 +95,35 @@ test('ls', t => {
|
94 | 95 | })
|
95 | 96 |
|
96 | 97 | test('ls stream with no options', t => {
|
| 98 | + t.plan(2) |
97 | 99 | const roster = {
|
98 | 100 | zkat: 'developer',
|
99 | 101 | iarna: 'admin',
|
100 | 102 | isaacs: 'owner'
|
101 | 103 | }
|
102 | 104 | const rosterArr = Object.keys(roster).map(k => [k, roster[k]])
|
103 | 105 | tnock(t, REG).get('/-/org/myorg/user').reply(200, roster)
|
104 |
| - return org.ls.stream('myorg').then(res => { |
105 |
| - t.deepEqual(res, rosterArr, 'got back a roster, in entries format') |
106 |
| - }) |
| 106 | + const result = org.ls.stream('myorg') |
| 107 | + t.ok(Minipass.isStream(result), 'returns a stream') |
| 108 | + return result.collect() |
| 109 | + .then(res => { |
| 110 | + t.deepEqual(res, rosterArr, 'got back a roster, in entries format') |
| 111 | + }) |
107 | 112 | })
|
108 | 113 |
|
109 | 114 | test('ls stream', t => {
|
| 115 | + t.plan(2) |
110 | 116 | const roster = {
|
111 | 117 | zkat: 'developer',
|
112 | 118 | iarna: 'admin',
|
113 | 119 | isaacs: 'owner'
|
114 | 120 | }
|
115 | 121 | const rosterArr = Object.keys(roster).map(k => [k, roster[k]])
|
116 | 122 | tnock(t, OPTS.registry).get('/-/org/myorg/user').reply(200, roster)
|
117 |
| - return org.ls.stream('myorg', OPTS).then(res => { |
118 |
| - t.deepEqual(res, rosterArr, 'got back a roster, in entries format') |
119 |
| - }) |
| 123 | + const result = org.ls.stream('myorg', OPTS) |
| 124 | + t.ok(Minipass.isStream(result), 'returns a stream') |
| 125 | + return result.collect() |
| 126 | + .then(res => { |
| 127 | + t.deepEqual(res, rosterArr, 'got back a roster, in entries format') |
| 128 | + }) |
120 | 129 | })
|
0 commit comments