Socket
Socket
Sign inDemoInstall

memfs

Package Overview
Dependencies
1
Maintainers
1
Versions
141
Alerts
File Explorer

Advanced tools

Install Socket

Detect and block malicious and high-risk dependencies

Install

Comparing version 4.7.4 to 4.7.5-next.1

lib/thingies/concurrency.d.ts

2

lib/crud-to-cas/__tests__/testCasfs.js
"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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc