memfs
Advanced tools
Comparing version 4.7.4 to 4.7.5-next.1
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.testCasfs = exports.hash = void 0; | ||
const thingies_1 = require("thingies"); | ||
const thingies_1 = require("../../thingies"); | ||
const crypto_1 = require("crypto"); | ||
@@ -6,0 +6,0 @@ const util_1 = require("../util"); |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.testCrudfs = void 0; | ||
const thingies_1 = require("thingies"); | ||
const thingies_1 = require("../../thingies"); | ||
const b = (str) => { | ||
@@ -6,0 +6,0 @@ const buf = Buffer.from(str); |
@@ -6,4 +6,12 @@ "use strict"; | ||
const FsaNodeFs_1 = require("../FsaNodeFs"); | ||
const thingies_1 = require("thingies"); | ||
const thingies_1 = require("../../thingies"); | ||
const util_1 = require("../../__tests__/util"); | ||
const tick = (ms = 1) => new Promise(r => setTimeout(r, ms)); | ||
const until = async (check, pollInterval = 1) => { | ||
do { | ||
if (await check()) | ||
return; | ||
await tick(pollInterval); | ||
} while (true); | ||
}; | ||
const setup = (json = null, mode = 'readwrite') => { | ||
@@ -750,3 +758,3 @@ const { fs: mfs, vol } = (0, __1.memfs)({ mountpoint: json }); | ||
stream.end(); | ||
await (0, thingies_1.until)(async () => { | ||
await until(async () => { | ||
const [, error] = await (0, thingies_1.of)(stat()); | ||
@@ -771,3 +779,3 @@ return !!error; | ||
stream.end(); | ||
await (0, thingies_1.tick)(200); | ||
await tick(200); | ||
await stat(); | ||
@@ -774,0 +782,0 @@ }); |
/// <reference types="node" /> | ||
import { Readable } from 'stream'; | ||
import { Defer } from 'thingies/es6/Defer'; | ||
import { Defer } from '../thingies/Defer'; | ||
import type { FsaNodeFsOpenFile } from './FsaNodeFsOpenFile'; | ||
@@ -16,3 +16,3 @@ import type { IReadStream } from '../node/types/misc'; | ||
protected __bytes__: number; | ||
protected readonly __mutex__: <T = unknown>(code: import("thingies/es6/types").Code<T>) => Promise<T>; | ||
protected readonly __mutex__: <T = unknown>(code: import("../thingies/types").Code<T>) => Promise<T>; | ||
protected readonly __file__: Defer<FsaNodeFsOpenFile>; | ||
@@ -19,0 +19,0 @@ constructor(fs: FsaNodeFs, handle: Promise<FsaNodeFsOpenFile>, path: string, options: IReadStreamOptions); |
@@ -5,4 +5,4 @@ "use strict"; | ||
const stream_1 = require("stream"); | ||
const Defer_1 = require("thingies/es6/Defer"); | ||
const concurrency_1 = require("thingies/es6/concurrency"); | ||
const Defer_1 = require("../thingies/Defer"); | ||
const concurrency_1 = require("../thingies/concurrency"); | ||
class FsaNodeReadStream extends stream_1.Readable { | ||
@@ -9,0 +9,0 @@ constructor(fs, handle, path, options) { |
@@ -35,3 +35,3 @@ /// <reference types="node" /> | ||
protected readonly __stream__: Promise<IFileSystemWritableFileStream>; | ||
protected readonly __mutex__: <T = unknown>(code: import("thingies/es6/types").Code<T>) => Promise<T>; | ||
protected readonly __mutex__: <T = unknown>(code: import("../thingies/types").Code<T>) => Promise<T>; | ||
constructor(handle: Promise<FsaNodeFsOpenFile>, path: string, options: IWriteStreamOptions); | ||
@@ -38,0 +38,0 @@ private ___write___; |
@@ -5,4 +5,4 @@ "use strict"; | ||
const stream_1 = require("stream"); | ||
const Defer_1 = require("thingies/es6/Defer"); | ||
const concurrency_1 = require("thingies/es6/concurrency"); | ||
const Defer_1 = require("../thingies/Defer"); | ||
const concurrency_1 = require("../thingies/concurrency"); | ||
const util_1 = require("../node/util"); | ||
@@ -9,0 +9,0 @@ const queueMicrotask_1 = require("../queueMicrotask"); |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.FsaNodeSyncAdapterWorker = void 0; | ||
const Defer_1 = require("thingies/es6/Defer"); | ||
const Defer_1 = require("../../thingies/Defer"); | ||
const SyncMessenger_1 = require("./SyncMessenger"); | ||
@@ -6,0 +6,0 @@ const json_1 = require("../json"); |
{ | ||
"name": "memfs", | ||
"version": "4.7.4", | ||
"version": "4.7.5-next.1", | ||
"description": "In-memory file-system with Node's fs API.", | ||
@@ -62,4 +62,4 @@ "keywords": [ | ||
"demo:webfs": "webpack serve --config ./src/webfs/webpack.config.js", | ||
"prettier": "prettier --ignore-path .gitignore --write \"src/**/*.{ts,js}\"", | ||
"prettier:diff": "prettier -l \"src/**/*.{ts,js}\"", | ||
"prettier": "prettier --write .", | ||
"prettier:check": "prettier --check .", | ||
"test": "jest --maxWorkers 2", | ||
@@ -125,3 +125,2 @@ "test:coverage": "jest --coverage", | ||
"dependencies": { | ||
"thingies": "^1.11.1", | ||
"tslib": "^2.0.0" | ||
@@ -143,4 +142,3 @@ }, | ||
"path-browserify": "^1.0.1", | ||
"prettier": "^2.7.1", | ||
"pretty-quick": "^4.0.0", | ||
"prettier": "^3.0.0", | ||
"process": "^0.11.10", | ||
@@ -147,0 +145,0 @@ "readable-stream": "^4.4.0", |
@@ -12,3 +12,2 @@ # memfs | ||
## Install | ||
@@ -20,3 +19,2 @@ | ||
## Docs | ||
@@ -32,3 +30,2 @@ | ||
## Demos | ||
@@ -43,3 +40,2 @@ | ||
## See also | ||
@@ -57,5 +53,4 @@ | ||
## License | ||
Apache 2.0 |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
1146299
1
30
424
16250
1
52
- Removedthingies@^1.11.1
- Removedthingies@1.21.0(transitive)