|
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