Functions — github.com/WinterTC55/iter-streams

hub / github.com/WinterTC55/iter-streams / functions

Functions947 in github.com/WinterTC55/iter-streams

⨍ Functions 947◇ Types & classes 113

↓ 3 callersFunctionisUint8ArrayBatch

* Check if result is already a Uint8Array[] (fast path).

src/pull.js:627

↓ 3 callersFunctionmakeSource

(id: number)

samples/10-merging-concat.ts:138

↓ 3 callersFunctionmean

* Calculate mean of an array

benchmarks/utils.ts:53

↓ 3 callersFunctionmessageSource

()

samples/01-basic-creation.ts:196

↓ 3 callersFunctionnormalizeAsyncSource

* Normalize an async streamable source, yielding batches of Uint8Array. * * @param source - The async streamable source (can be sync or async iterab

src/from.js:498

↓ 3 callersFunctionnormalizeSyncSource

* Normalize a sync streamable source, yielding batches of Uint8Array. * * @param source - The sync streamable source * @yields Uint8Array[] batches

src/from.js:287

↓ 3 callersMethodrejectPendingWrites

* Reject all pending writes with an error.

src/broadcast.ts:628

↓ 3 callersFunctionserverLogs

(name: string, delay: number)

samples/10-merging-concat.ts:274

↓ 3 callersFunctionsettle

(resolve, reject, d, v)

src/consumers.js:50

↓ 3 callersFunctionsettle

(resolve, reject, d, v)

src/from.js:41

↓ 3 callersFunctionsettle

(resolve, reject, d, v)

src/pull.js:50

↓ 3 callersFunctionsource

()

samples/09-resource-management.ts:28

↓ 3 callersFunctionsource

()

benchmarks/01-throughput.ts:406

↓ 3 callersMethodtryTrimBuffer

* Trim buffer from front if all consumers have advanced. * Notifies writer if buffer space becomes available.

src/broadcast.ts:400

↓ 3 callersFunctionuppercaseByte

(b: number)

benchmarks/bench-bun-file-streams.ts:67

↓ 3 callersFunctionuppercaseByte

(b: number)

benchmarks/bench-deno-file-streams.ts:64

↓ 3 callersFunctionverb

(n)

samples/util.js:14

↓ 3 callersFunctionverb

(n)

src/share.js:20

↓ 3 callersFunctionverb

(n)

src/ringbuffer.js:5

↓ 3 callersFunctionverb

(n)

src/duplex.js:20

↓ 3 callersFunctionverb

(n)

src/push.js:20

↓ 3 callersFunctionxorTS

()

benchmarks/20-memory-allocations.ts:42

↓ 3 callersFunctionxorTS

()

benchmarks/21-memory-sustained.ts:45

↓ 2 callersMethod_getDesiredSize

* Check if we can accept more writes (for desiredSize).

src/broadcast.ts:374

↓ 2 callersMethod_notifyConsumers

* Notify consumers that have pending reads.

src/broadcast.ts:417

↓ 2 callersMethod_writevSlow

(chunks: (Uint8Array | string)[], options?: WriteOptions)

src/broadcast.ts:527

↓ 2 callersFunctionaddPrefix

(prefix: string)

samples/10-merging-concat.ts:357

↓ 2 callersFunctionarrayBuffer

* Collect bytes as ArrayBuffer from an async or sync source. * * @param source - Iterable or async iterable yielding Uint8Array[] batches * @param

src/consumers.js:370

↓ 2 callersFunctionarrayBufferSync

* Collect bytes as ArrayBuffer from a sync source. * * @param source - Sync iterable yielding Uint8Array[] batches * @param options - Optional limi

src/consumers.js:145

↓ 2 callersFunctionbytes

( source: AsyncIterable<Uint8Array[]> | Iterable<Uint8Array[]>, options?: ConsumeOptions )

src/consumers.ts:157

↓ 2 callersFunctionbytesSync

( source: Iterable<Uint8Array[]>, options?: ConsumeSyncOptions )

src/consumers.ts:55

↓ 2 callersFunctioncollect

(source: AsyncIterable<Uint8Array[]>)

src/duplex.test.ts:19

↓ 2 callersFunctioncollect

(r)

benchmarks/html/benchmarks.js:232

↓ 2 callersMethodconsumerReturn

* Consumer returned early (break from iteration).

src/push.ts:406

↓ 2 callersMethodconsumerThrow

* Consumer threw an error.

src/push.ts:421

↓ 2 callersFunctioncreateAsyncPipeline

* Create an async pipeline from source through transforms.

src/pull.ts:466

↓ 2 callersFunctioncreateAsyncPipeline

* Create an async pipeline from source through transforms.

src/pull.js:958

↓ 2 callersMethodcreatePendingWrite

* Create a pending write promise, optionally racing against a signal. * Same pattern as PushQueue.createPendingWrite().

src/broadcast.ts:577

↓ 2 callersFunctioncreateRandom

* Simple seeded random number generator for reproducible text. * Using a simple Linear Congruential Generator.

samples/cloudflare-worker/src/index.ts:59

↓ 2 callersFunctioncreateSyncPipeline

* Create a sync pipeline from source through transforms.

src/pull.ts:324

↓ 2 callersFunctioncreateSyncPipeline

* Create a sync pipeline from source through transforms.

src/pull.js:587

↓ 2 callersFunctioncreateWebWriter

* Create a Writer that writes to a Web WritableStream. * * Features: * - Proper backpressure handling (waits for ready) * - Error propagation * -

samples/13-web-streams-interop.ts:133

↓ 2 callersMethodfail

(reason?: any)

samples/util.ts:77

↓ 2 callersMethodfail

* Put queue into terminal error state.

src/push.ts:338

↓ 2 callersFunctionflattenTransformYieldSync

* Flatten transform yield to Uint8Array chunks (sync).

src/pull.ts:130

↓ 2 callersFunctionflattenTransformYieldSync

* Flatten transform yield to Uint8Array chunks (sync).

src/pull.js:160

↓ 2 callersFunctionfmt

(r: BenchmarkResult)

benchmarks/17-bun-direct-streams.ts:161

↓ 2 callersFunctionfmtMs

(ms: number)

benchmarks/21-memory-sustained.ts:212

↓ 2 callersFunctionfmtPct

(part: number, whole: number)

benchmarks/21-memory-sustained.ts:216

↓ 2 callersFunctioninfiniteSource

(id: string)

samples/10-merging-concat.ts:165

↓ 2 callersFunctioninner

()

src/from.test.ts:129

↓ 2 callersFunctionisPullOptions

* Check if a value is PullOptions (object without transform or write property).

src/utils.js:70

↓ 2 callersFunctionisToAsyncStreamable

* Check if value implements ToAsyncStreamable protocol.

src/from.js:118

↓ 2 callersFunctionisToAsyncStreamable

* Check if value implements ToAsyncStreamable protocol.

src/from.ts:59

↓ 2 callersFunctionisUint8ArrayBatch

* Check if value is already a Uint8Array[] batch (fast path check).

src/from.js:484

↓ 2 callersFunctionisUint8ArrayBatch

* Check if value is already a Uint8Array[] batch (fast path check).

src/from.ts:348

↓ 2 callersFunctionisWriter

* Check if a value is a Writer (has write method).

src/pull.ts:72

↓ 2 callersFunctionisWriter

* Check if a value is a Writer (has write method).

src/pull.js:119

↓ 2 callersFunctionmanyChunks

()

src/share.test.ts:111

↓ 2 callersFunctionnormalizeAsyncSource

* Normalize an async streamable source, yielding batches of Uint8Array. * * @param source - The async streamable source (can be sync or async iterab

src/from.ts:361

↓ 2 callersFunctionnormalizeAsyncValue

* Normalize an async streamable yield value to Uint8Array chunks. * Recursively flattens arrays, iterables, async iterables, promises, and protocol c

src/from.js:337

↓ 2 callersFunctionnormalizeAsyncValue

* Normalize an async streamable yield value to Uint8Array chunks. * Recursively flattens arrays, iterables, async iterables, promises, and protocol c

src/from.ts:269

↓ 2 callersFunctionparsePipeToArgs

* Parse variadic arguments for pipeTo/pipeToSync. * Returns { transforms, writer, options }

src/pull.ts:86

↓ 2 callersFunctionparsePipeToArgs

* Parse variadic arguments for pipeTo/pipeToSync. * Returns { transforms, writer, options }

src/pull.js:129

↓ 2 callersFunctionparsePullArgs

* Parse variadic arguments for pull/pullSync. * Returns { transforms, options }

src/utils.js:80

↓ 2 callersFunctionpercentile

* Calculate percentile

benchmarks/utils.ts:69

↓ 2 callersFunctionprocessTransformResultAsync

* Process transform result (async).

src/pull.ts:215

↓ 2 callersFunctionprocessTransformResultAsync

* Process transform result (async).

src/pull.js:323

↓ 2 callersFunctionpull

(controller)

benchmarks/04-pipelines.ts:55

↓ 2 callersFunctionreject

(value)

src/consumers.js:62

↓ 2 callersFunctionreject

(value)

src/pull.js:66

↓ 2 callersMethodrejectPendingDrains

* Reject all pending drains with an error.

src/broadcast.ts:649

↓ 2 callersMethodrejectPendingReads

* Reject all pending reads with an error.

src/push.ts:518

↓ 2 callersMethodsetWriter

src/broadcast.ts:114

↓ 2 callersFunctionsource

()

samples/13-web-streams-interop.ts:421

↓ 2 callersFunctionsource1

()

samples/10-merging-concat.ts:322

↓ 2 callersFunctionsource2

()

samples/10-merging-concat.ts:327

↓ 2 callersFunctionstartIterator

(state: IteratorState, index: number)

src/consumers.ts:539

↓ 2 callersFunctionstep

(op)

src/from.js:12

↓ 2 callersFunctiontap

* Create a pass-through transform that observes chunks without modifying them. * Useful for logging, hashing, metrics, etc. * * @param callback - C

src/consumers.js:550

↓ 2 callersFunctiontapSync

* Create a sync pass-through transform that observes chunks without modifying them. * * @param callback - Called with each batch or null (flush sign

src/consumers.js:569

↓ 2 callersMethodthrow

(_error?: Error)

src/share.ts:201

↓ 2 callersFunctiontoHex

* Convert bytes to hex string

samples/cloudflare-worker/src/index.ts:70

↓ 2 callersMethodtoString

()

src/from.test.ts:221

↓ 2 callersFunctiontryStringCoercion

* Try to coerce an object to string using custom methods. * Returns null if object has no custom string coercion.

src/from.js:182

↓ 2 callersFunctiontryStringCoercion

* Try to coerce an object to string using custom methods. * Returns null if object has no custom string coercion.

src/from.ts:138

↓ 2 callersMethodunshift

* Prepend an item to the head. O(1) amortized.

src/ringbuffer.ts:39

↓ 2 callersMethodwaitForBufferSpace

* Wait for buffer space based on backpressure policy. * Returns false if cancelled while waiting, or throws if strict policy.

src/share.ts:264

↓ 2 callersMethodwaitForDrain

* Wait for backpressure to clear (desiredSize > 0). * Returns a Promise that: * - Resolves with `true` when buffer has space * - Resolves wit

src/push.ts:366

↓ 2 callersMethodwrite

(chunk: Uint8Array | string, _options?: WriteOptions)

benchmarks/10-advanced-features.ts:360

↓ 2 callersMethodwriteSync

(chunk: Uint8Array | string)

benchmarks/10-advanced-features.ts:371

↓ 2 callersMethodwritevSync

Try to writev synchronously. Returns true if successful, false if buffer full.

src/types.ts:188

↓ 1 callersFunctionadopt

(value)

samples/util.js:3

↓ 1 callersFunctionadopt

(value)

src/share.js:9

↓ 1 callersFunctionadopt

(value)

src/consumers.js:10

↓ 1 callersFunctionadopt

(value)

src/duplex.js:9

↓ 1 callersFunctionadopt

(value)

src/broadcast.js:9

↓ 1 callersFunctionadopt

(value)

src/pull.js:9

↓ 1 callersFunctionadopt

(value)

src/push.js:9

↓ 1 callersFunctionapplyStatefulAsyncTransform

* Apply a single stateful async transform to a source.

src/pull.ts:425

← previous next →201–300 of 947, ranked by callers