Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

react-streaming

Package Overview
Dependencies
Maintainers
0
Versions
100
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

react-streaming - npm Package Compare versions

Comparing version 0.3.39 to 0.3.40-commit-1854445

dist/cjs/server/renderToStream/orchestrateWrites.d.ts
dist/cjs/server/renderToStream/orchestrateWrites.js
dist/esm/server/renderToStream/orchestrateWrites.d.ts
dist/esm/server/renderToStream/orchestrateWrites.js

2

dist/cjs/server/index.d.ts
export { renderToStream, disable };
export type { InjectToStream };
import { renderToStream, disable } from './renderToStream';
import type { InjectToStream } from './renderToStream/createBuffer';
import type { InjectToStream } from './renderToStream/orchestrateWrites';

4

dist/cjs/server/renderToStream/createPipeWrapper.d.ts

@@ -5,3 +5,3 @@ /// <reference types="node" />

import type { Writable as StreamNodeWritable } from 'stream';
import { type DoNotClosePromise } from './createBuffer';
import { type DoNotClosePromise } from './orchestrateWrites';
import type { ClearTimeouts } from '../renderToStream';

@@ -12,4 +12,4 @@ declare type Pipe = (writable: StreamNodeWritable) => void;

streamEnd: Promise<void>;
injectToStream: import("./createBuffer").InjectToStream;
injectToStream: import("./orchestrateWrites").InjectToStream;
hasStreamEnded: () => boolean;
}>;

4

dist/cjs/server/renderToStream/createPipeWrapper.js

@@ -5,3 +5,3 @@ "use strict";

const utils_1 = require("../utils");
const createBuffer_1 = require("./createBuffer");
const orchestrateWrites_1 = require("./orchestrateWrites");
const debug = (0, utils_1.createDebugger)('react-streaming:createPipeWrapper');

@@ -14,3 +14,3 @@ const stream_1 = require("stream");

};
const { injectToStream, onReactWrite, onBeforeEnd, hasStreamEnded } = (0, createBuffer_1.createBuffer)(streamOperations, doNotClosePromise);
const { injectToStream, onReactWrite, onBeforeEnd, hasStreamEnded } = (0, orchestrateWrites_1.orchestrateWrites)(streamOperations, doNotClosePromise);
return { pipeForUser, streamEnd, injectToStream, hasStreamEnded };

@@ -17,0 +17,0 @@ function createPipeForUser() {

4

dist/cjs/server/renderToStream/createReadableWrapper.d.ts
export { createReadableWrapper };
import { type DoNotClosePromise } from './createBuffer';
import { type DoNotClosePromise } from './orchestrateWrites';
import type { ClearTimeouts } from '../renderToStream';

@@ -7,4 +7,4 @@ declare function createReadableWrapper(readableFromReact: ReadableStream, clearTimeouts: ClearTimeouts, doNotClosePromise: DoNotClosePromise): {

streamEnd: Promise<void>;
injectToStream: import("./createBuffer").InjectToStream;
injectToStream: import("./orchestrateWrites").InjectToStream;
hasStreamEnded: () => boolean;
};

4

dist/cjs/server/renderToStream/createReadableWrapper.js
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.createReadableWrapper = void 0;
const createBuffer_1 = require("./createBuffer");
const orchestrateWrites_1 = require("./orchestrateWrites");
// `readableFromReact` is the readable stream provided by React.

@@ -23,3 +23,3 @@ // `readableForUser` is the readable stream we give to the user (the wrapper).

});
const { injectToStream, onReactWrite, onBeforeEnd, hasStreamEnded } = (0, createBuffer_1.createBuffer)(streamOperations, doNotClosePromise);
const { injectToStream, onReactWrite, onBeforeEnd, hasStreamEnded } = (0, orchestrateWrites_1.orchestrateWrites)(streamOperations, doNotClosePromise);
return { readableForUser, streamEnd, injectToStream, hasStreamEnded };

@@ -26,0 +26,0 @@ async function onReady(onEnded) {

4

dist/cjs/server/renderToStream/renderToNodeStream.d.ts

@@ -5,3 +5,3 @@ export { renderToNodeStream };

import type { ClearTimeouts, SetAbortFn, StreamOptions } from '../renderToStream';
import type { DoNotClosePromise } from './createBuffer';
import type { DoNotClosePromise } from './orchestrateWrites';
declare function renderToNodeStream(element: React.ReactNode, disable: boolean, options: {

@@ -16,4 +16,4 @@ onBoundaryError?: (err: unknown) => void;

streamEnd: Promise<boolean>;
injectToStream: import("./createBuffer").InjectToStream;
injectToStream: import("./orchestrateWrites").InjectToStream;
hasStreamEnded: () => boolean;
}>;

4

dist/cjs/server/renderToStream/renderToWebStream.d.ts

@@ -5,3 +5,3 @@ export { renderToWebStream };

import type { ClearTimeouts, SetAbortFn, StreamOptions } from '../renderToStream';
import type { DoNotClosePromise } from './createBuffer';
import type { DoNotClosePromise } from './orchestrateWrites';
declare function renderToWebStream(element: React.ReactNode, disable: boolean, options: {

@@ -19,4 +19,4 @@ onBoundaryError?: (err: unknown) => void;

streamEnd: Promise<boolean>;
injectToStream: import("./createBuffer").InjectToStream;
injectToStream: import("./orchestrateWrites").InjectToStream;
hasStreamEnded: () => boolean;
}>;

2

dist/cjs/utils/debug.d.ts

@@ -10,3 +10,3 @@ export { createDebugger };

};
declare type Namespace = 'react-streaming:createPipeWrapper' | 'react-streaming:buffer' | 'react-streaming:flow';
declare type Namespace = 'react-streaming:createPipeWrapper' | 'react-streaming:writes' | 'react-streaming:flow';
declare function createDebugger(namespace: Namespace, optionsGlobal?: Options): ((msg: string, info?: unknown) => void) & {

@@ -13,0 +13,0 @@ options: (options: Options) => (msg: string, info?: unknown) => void;

2

dist/cjs/utils/projectInfo.js

@@ -5,3 +5,3 @@ "use strict";

const getGlobalObject_1 = require("./getGlobalObject");
const PROJECT_VERSION = '0.3.39';
const PROJECT_VERSION = '0.3.40-commit-1854445';
const projectInfo = {

@@ -8,0 +8,0 @@ projectName: 'react-streaming',

2

dist/esm/server/index.d.ts
export { renderToStream, disable };
export type { InjectToStream };
import { renderToStream, disable } from './renderToStream';
import type { InjectToStream } from './renderToStream/createBuffer';
import type { InjectToStream } from './renderToStream/orchestrateWrites';

4

dist/esm/server/renderToStream/createPipeWrapper.d.ts

@@ -5,3 +5,3 @@ /// <reference types="node" />

import type { Writable as StreamNodeWritable } from 'stream';
import { type DoNotClosePromise } from './createBuffer';
import { type DoNotClosePromise } from './orchestrateWrites';
import type { ClearTimeouts } from '../renderToStream';

@@ -12,4 +12,4 @@ declare type Pipe = (writable: StreamNodeWritable) => void;

streamEnd: Promise<void>;
injectToStream: import("./createBuffer").InjectToStream;
injectToStream: import("./orchestrateWrites").InjectToStream;
hasStreamEnded: () => boolean;
}>;

4

dist/esm/server/renderToStream/createPipeWrapper.js
export { createPipeWrapper };
import { createDebugger } from '../utils';
import { createBuffer } from './createBuffer';
import { orchestrateWrites } from './orchestrateWrites';
const debug = createDebugger('react-streaming:createPipeWrapper');

@@ -11,3 +11,3 @@ import { Writable } from 'stream';

};
const { injectToStream, onReactWrite, onBeforeEnd, hasStreamEnded } = createBuffer(streamOperations, doNotClosePromise);
const { injectToStream, onReactWrite, onBeforeEnd, hasStreamEnded } = orchestrateWrites(streamOperations, doNotClosePromise);
return { pipeForUser, streamEnd, injectToStream, hasStreamEnded };

@@ -14,0 +14,0 @@ function createPipeForUser() {

4

dist/esm/server/renderToStream/createReadableWrapper.d.ts
export { createReadableWrapper };
import { type DoNotClosePromise } from './createBuffer';
import { type DoNotClosePromise } from './orchestrateWrites';
import type { ClearTimeouts } from '../renderToStream';

@@ -7,4 +7,4 @@ declare function createReadableWrapper(readableFromReact: ReadableStream, clearTimeouts: ClearTimeouts, doNotClosePromise: DoNotClosePromise): {

streamEnd: Promise<void>;
injectToStream: import("./createBuffer").InjectToStream;
injectToStream: import("./orchestrateWrites").InjectToStream;
hasStreamEnded: () => boolean;
};

4

dist/esm/server/renderToStream/createReadableWrapper.js
export { createReadableWrapper };
import { createBuffer } from './createBuffer';
import { orchestrateWrites } from './orchestrateWrites';
// `readableFromReact` is the readable stream provided by React.

@@ -21,3 +21,3 @@ // `readableForUser` is the readable stream we give to the user (the wrapper).

});
const { injectToStream, onReactWrite, onBeforeEnd, hasStreamEnded } = createBuffer(streamOperations, doNotClosePromise);
const { injectToStream, onReactWrite, onBeforeEnd, hasStreamEnded } = orchestrateWrites(streamOperations, doNotClosePromise);
return { readableForUser, streamEnd, injectToStream, hasStreamEnded };

@@ -24,0 +24,0 @@ async function onReady(onEnded) {

4

dist/esm/server/renderToStream/renderToNodeStream.d.ts

@@ -5,3 +5,3 @@ export { renderToNodeStream };

import type { ClearTimeouts, SetAbortFn, StreamOptions } from '../renderToStream';
import type { DoNotClosePromise } from './createBuffer';
import type { DoNotClosePromise } from './orchestrateWrites';
declare function renderToNodeStream(element: React.ReactNode, disable: boolean, options: {

@@ -16,4 +16,4 @@ onBoundaryError?: (err: unknown) => void;

streamEnd: Promise<boolean>;
injectToStream: import("./createBuffer").InjectToStream;
injectToStream: import("./orchestrateWrites").InjectToStream;
hasStreamEnded: () => boolean;
}>;

4

dist/esm/server/renderToStream/renderToWebStream.d.ts

@@ -5,3 +5,3 @@ export { renderToWebStream };

import type { ClearTimeouts, SetAbortFn, StreamOptions } from '../renderToStream';
import type { DoNotClosePromise } from './createBuffer';
import type { DoNotClosePromise } from './orchestrateWrites';
declare function renderToWebStream(element: React.ReactNode, disable: boolean, options: {

@@ -19,4 +19,4 @@ onBoundaryError?: (err: unknown) => void;

streamEnd: Promise<boolean>;
injectToStream: import("./createBuffer").InjectToStream;
injectToStream: import("./orchestrateWrites").InjectToStream;
hasStreamEnded: () => boolean;
}>;

2

dist/esm/utils/debug.d.ts

@@ -10,3 +10,3 @@ export { createDebugger };

};
declare type Namespace = 'react-streaming:createPipeWrapper' | 'react-streaming:buffer' | 'react-streaming:flow';
declare type Namespace = 'react-streaming:createPipeWrapper' | 'react-streaming:writes' | 'react-streaming:flow';
declare function createDebugger(namespace: Namespace, optionsGlobal?: Options): ((msg: string, info?: unknown) => void) & {

@@ -13,0 +13,0 @@ options: (options: Options) => (msg: string, info?: unknown) => void;

2

dist/esm/utils/projectInfo.js
export { projectInfo };
import { getGlobalObject } from './getGlobalObject';
const PROJECT_VERSION = '0.3.39';
const PROJECT_VERSION = '0.3.40-commit-1854445';
const projectInfo = {

@@ -5,0 +5,0 @@ projectName: 'react-streaming',

2

package.json
{
"name": "react-streaming",
"description": "React 18 Streaming. Full-fledged & Easy.",
"version": "0.3.39",
"version": "0.3.40-commit-1854445",
"peerDependencies": {

@@ -6,0 +6,0 @@ "react": ">=18",

dist/cjs/server/renderToStream/createBuffer.d.ts
dist/cjs/server/renderToStream/createBuffer.js
dist/esm/server/renderToStream/createBuffer.d.ts
dist/esm/server/renderToStream/createBuffer.js
SocketSocket SOC 2 Logo

Product

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

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc