pzp
/
pzp-net
mirror of https://codeberg.org/pzp/pzp-net.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix scheduler start()

This commit is contained in:
Andre Staltz 2024-02-06 15:35:11 +02:00
parent 809d3e774b
commit 5b79b9566b
No known key found for this signature in database
GPG Key ID: 9EDE23EA7E8A4890
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
lib/scheduler.js
View File

@ -22,6 +22,8 @@ class Scheduler {
#peer #peer
/** @type {Connections} */ /** @type {Connections} */
#connections #connections
/** @type {boolean} */
#closed
/** /**
* @param {Peer} peer * @param {Peer} peer
@ -30,15 +32,18 @@ class Scheduler {
constructor(peer, connections) { constructor(peer, connections) {
this.#peer = peer this.#peer = peer
this.#connections = connections this.#connections = connections
this.#closed = true
} }
/** /**
* @param {Multiaddr} multiaddr * @param {Multiaddr} multiaddr
*/ */
async #scheduleWithHub(multiaddr) { async #scheduleWithHub(multiaddr) {
/** @type {[Error, null] | [null, any]} */ /**@type {any}*/
const [err, hubRPC] = await run(this.#connections.connect)(multiaddr) let hubRPC
if (err) { try {
hubRPC = await this.#connections.connect(multiaddr)
} catch (err) {
debug('Failed to connect to hub at "%s" because %o', multiaddr, err) debug('Failed to connect to hub at "%s" because %o', multiaddr, err)
return return
} }
@ -73,13 +78,13 @@ class Scheduler {
} }
start() { start() {
if (!this.closed) return if (!this.#closed) return
this.closed = false this.#closed = false
this.#setupHubDiscovery(); this.#setupHubDiscovery();
} }
stop() { stop() {
this.#closed = true
// FIXME: implement // FIXME: implement
} }
} }