()
| 223 | const t = new FirstFailTarget(); |
| 224 | const seen: string[] = []; |
| 225 | async function* withObserver(): AsyncIterable<Room> { |
| 226 | for (const name of ['a', 'b', 'c', 'd']) { |
| 227 | seen.push(name); |
| 228 | yield { name, snapshot: '', log: [], audit: [], chat: [], ecell: {} }; |
| 229 | } |
| 230 | } |
| 231 | await expect( |
| 232 | applyRoomStream(withObserver(), t, { concurrency: 1 }), |
| 233 | ).rejects.toThrow('first-fail'); |