diff --git a/test/sync.test.js b/test/sync.test.js index ba7fb65..3a88764 100644 --- a/test/sync.test.js +++ b/test/sync.test.js @@ -698,27 +698,22 @@ describe('Sync protocol', function () { }) it('does not crash when no listeners are attached to the `error` event on `Sync.events`', async () => { - let err = null + let synced = null - const onError = (error) => { - (!err) && (err = error) + const onSynced = (data) => { + synced = data; } sync1 = await Sync({ ipfs: ipfs1, log: log1, timeout: timeoutTime }) - sync2 = await Sync({ ipfs: ipfs2, log: log2, start: false, timeout: timeoutTime }) - - // `sync1.events` has no listener on `error` - sync2.events.on('error', onError) + sync2 = await Sync({ ipfs: ipfs2, log: log2, start: false, onSynced: onSynced, timeout: timeoutTime }) await log1.append('hello1') await sync2.start() - await waitFor(() => err !== null, () => true) + await waitFor(() => !!synced, () => true) notStrictEqual(err, null) - strictEqual(err.type, 'aborted') - strictEqual(err.message, 'Read aborted') }) })