|
1 |
| -import PQueue from 'p-queue' |
2 |
| -import type { AbortOptions } from '@libp2p/interfaces' |
3 |
| -import type { ContentRouting } from '@libp2p/interface-content-routing' |
4 |
| -import type { PeerInfo } from '@libp2p/interface-peer-info' |
5 |
| -import type { Startable } from '@libp2p/interfaces/startable' |
6 |
| -import type { CID } from 'multiformats/cid' |
| 1 | +import { CodeError } from '@libp2p/interfaces/errors' |
| 2 | +import { logger } from '@libp2p/logger' |
7 | 3 | import { peerIdFromString } from '@libp2p/peer-id'
|
8 | 4 | import { multiaddr } from '@multiformats/multiaddr'
|
9 |
| -import { logger } from '@libp2p/logger' |
10 |
| -import defer from 'p-defer' |
11 | 5 | import { anySignal } from 'any-signal'
|
12 |
| -import type { Multiaddr } from '@multiformats/multiaddr' |
13 |
| -import { CodeError } from '@libp2p/interfaces/errors' |
14 | 6 | import toIt from 'browser-readablestream-to-it'
|
15 | 7 | import toBuffer from 'it-to-buffer'
|
| 8 | +import defer from 'p-defer' |
| 9 | +import PQueue from 'p-queue' |
16 | 10 | import { toString as uint8ArrayToString } from 'uint8arrays/to-string'
|
| 11 | +import type { ContentRouting } from '@libp2p/interface-content-routing' |
| 12 | +import type { PeerInfo } from '@libp2p/interface-peer-info' |
| 13 | +import type { AbortOptions } from '@libp2p/interfaces' |
| 14 | +import type { Startable } from '@libp2p/interfaces/startable' |
| 15 | +import type { Multiaddr } from '@multiformats/multiaddr' |
| 16 | +import type { CID } from 'multiformats/cid' |
17 | 17 |
|
18 | 18 | const log = logger('reframe-content-routing')
|
19 | 19 |
|
@@ -94,7 +94,7 @@ class ReframeContentRouting implements ContentRouting, Startable {
|
94 | 94 |
|
95 | 95 | void this.httpQueue.add(async () => {
|
96 | 96 | onStart.resolve()
|
97 |
| - return await onFinish.promise |
| 97 | + return onFinish.promise |
98 | 98 | })
|
99 | 99 |
|
100 | 100 | try {
|
|
0 commit comments