Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-07-06 04:22:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: Catch heads iterator errors.

Browse Source
This commit is contained in:
Hayden Young 2023-10-11 23:03:22 +01:00
parent 3b3f90501c
commit 0c3e7667f3
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/sync.js
View File

@ -142,15 +142,23 @@ const Sync = async ({ ipfs, log, events, onSynced, start, timeout }) => {
let started = false let started = false
const onPeerJoined = async (peerId) => { const onPeerJoined = async (peerId) => {
const heads = await log.heads() try {
events.emit('join', peerId, heads) const heads = await log.heads()
events.emit('join', peerId, heads)
} catch (err) {
console.log('onPeerJoined', ipfs.libp2p.peerId.toString())
}
} }
const sendHeads = async (source) => { const sendHeads = async (source) => {
return (async function * () { return (async function * () {
const heads = await log.heads() try {
for await (const { bytes } of heads) { const heads = await log.heads()
yield bytes for await (const { bytes } of heads) {
yield bytes
}
} catch (err) {
console.log('onPeerJoined', ipfs.libp2p.peerId.toString())
} }
})() })()
} }