|
1 | | -import extractDataFromBlock from '../../../utils/extract-data-from-block.js' |
2 | | -import validateOffsetAndLength from '../../../utils/validate-offset-and-length.js' |
3 | | -import { UnixFS } from 'ipfs-unixfs' |
4 | | -import errCode from 'err-code' |
5 | 1 | import * as dagPb from '@ipld/dag-pb' |
6 | | -import * as raw from 'multiformats/codecs/raw' |
7 | | -import { Pushable, pushable } from 'it-pushable' |
| 2 | +import errCode from 'err-code' |
| 3 | +import { UnixFS } from 'ipfs-unixfs' |
| 4 | +import map from 'it-map' |
8 | 5 | import parallel from 'it-parallel' |
9 | 6 | import { pipe } from 'it-pipe' |
10 | | -import map from 'it-map' |
| 7 | +import { type Pushable, pushable } from 'it-pushable' |
| 8 | +import * as raw from 'multiformats/codecs/raw' |
11 | 9 | import PQueue from 'p-queue' |
12 | | -import type { ExporterOptions, UnixfsV1FileContent, UnixfsV1Resolver, ReadableStorage, ExportProgress, ExportWalk } from '../../../index.js' |
13 | 10 | import { CustomProgressEvent } from 'progress-events' |
| 11 | +import extractDataFromBlock from '../../../utils/extract-data-from-block.js' |
| 12 | +import validateOffsetAndLength from '../../../utils/validate-offset-and-length.js' |
| 13 | +import type { ExporterOptions, UnixfsV1FileContent, UnixfsV1Resolver, ReadableStorage, ExportProgress, ExportWalk } from '../../../index.js' |
14 | 14 |
|
15 | 15 | async function walkDAG (blockstore: ReadableStorage, node: dagPb.PBNode | Uint8Array, queue: Pushable<Uint8Array>, streamPosition: bigint, start: bigint, end: bigint, options: ExporterOptions): Promise<void> { |
16 | 16 | // a `raw` node |
|
0 commit comments