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

↓ 6 callersMethodgetText

()

samples/util.ts:86

↓ 6 callersMethodgetText

()

samples/util.ts:126

↓ 6 callersFunctionpipeToSync

* Write a sync source through transforms to a sync writer. * * @param source - The sync source yielding Uint8Array[] batches * @param args - Variad

src/pull.js:1189

↓ 6 callersFunctionprocessChunk

(chunk: Uint8Array | null)

samples/14-compression.ts:67

↓ 6 callersFunctionreadBranch

(stream: ReadableStream<Uint8Array>)

benchmarks/05-tee-branching.ts:74

↓ 6 callersMethodrejectPendingDrains

* Reject all pending drains with an error.

src/push.ts:507

↓ 6 callersMethodresolvePendingReads

* Resolve pending reads if data is available.

src/push.ts:452

↓ 6 callersMethodtoString

()

samples/01-basic-creation.ts:230

↓ 6 callersFunctiontoUint8Array

* Convert a chunk (string or Uint8Array) to Uint8Array. * Strings are UTF-8 encoded.

src/utils.js:17

↓ 6 callersMethodtrimFront

* Remove `count` items from the head without returning them. O(count) for GC cleanup.

src/ringbuffer.ts:70

↓ 6 callersFunctionverb

(n)

src/broadcast.js:20

↓ 6 callersFunctionwriteBatch

(batch: Uint8Array[])

src/pull.ts:693

↓ 5 callersFunctionarray

* Collect all chunks as an array from an async or sync source. * * @param source - Iterable or async iterable yielding Uint8Array[] batches * @para

src/consumers.js:394

↓ 5 callersFunctionarraySync

* Collect all chunks as an array from a sync source. * * @param source - Sync iterable yielding Uint8Array[] batches * @param options - Optional li

src/consumers.js:160

↓ 5 callersMethodcancel

* Cancel all consumers and reject pending writes on the writer. * Sets ended=true so that subsequent _abort() calls early-return.

src/broadcast.ts:237

↓ 5 callersMethodcancel

* Cancel all consumers and close source.

src/share.ts:217

↓ 5 callersFunctionconsumeAsyncPipeline

* Consume async pipeline and return total bytes

benchmarks/08-pipeline-sync.ts:162

↓ 5 callersFunctionconsumeSyncPipeline

* Consume sync pipeline and return total bytes

benchmarks/08-pipeline-sync.ts:149

↓ 5 callersFunctionconsumeWeb

(stream: ReadableStream<Uint8Array>)

benchmarks/20-memory-allocations.ts:66

↓ 5 callersFunctionconsumeWeb

(stream: ReadableStream<Uint8Array>)

benchmarks/21-memory-sustained.ts:69

↓ 5 callersFunctionconsumeWebStream

* Consume a Web Stream and return total bytes

benchmarks/08-pipeline-sync.ts:133

↓ 5 callersFunctioncreateBunComparison

( scenario: string, newStream: BenchmarkResult, bunDirect: BenchmarkResult )

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

↓ 5 callersFunctioncreateMockSyncWriter

()

src/pull.test.ts:38

↓ 5 callersFunctioncreateNodeWriter

* Create a Writer that pipes to a Node.js Writable stream. * * Features: * - Proper backpressure handling (respects drain events) * - Error propag

samples/12-nodejs-interop.ts:76

↓ 5 callersFunctioncreateWebStreamPipeline

* Create a Web Streams pipeline with sync pull source and transforms

benchmarks/08-pipeline-sync.ts:98

↓ 5 callersFunctionderiveKey

(password: string, salt: Uint8Array, iterations = 100000)

samples/15-encryption.ts:544

↓ 5 callersFunctionformatSpeedup

(speedup: number, confidence: string)

benchmarks/utils.ts:417

↓ 5 callersFunctionisSyncIterable

* Check if value is a sync iterable (has Symbol.iterator).

src/from.ts:71

↓ 5 callersMethodresolvePendingWrites

* Resolve pending writes if buffer has space. * Also resolves pending drains when buffer has space.

src/push.ts:477

↓ 5 callersFunctionsource

()

benchmarks/09-sync-async-comparison.ts:121

↓ 5 callersFunctionsource

()

benchmarks/07-sync-generators.ts:45

↓ 5 callersFunctionstep

(result)

src/consumers.js:14

↓ 5 callersFunctionstep

(result)

src/pull.js:13

↓ 5 callersFunctiontextSync

* Collect and decode text from a sync source. * * @param source - Sync iterable yielding Uint8Array[] batches * @param options - Optional encoding

src/consumers.js:129

↓ 5 callersFunctiontoString

(bytes: Uint8Array)

src/push.test.ts:25

↓ 4 callersMethod_abort

* Signal error. Notifies all consumers and detaches them.

src/broadcast.ts:341

↓ 4 callersMethod_end

* Signal end of stream.

src/broadcast.ts:316

↓ 4 callersMethod_grow

* Double the backing capacity, linearizing the circular layout.

src/ringbuffer.ts:135

↓ 4 callersFunctioncollectNodeStreamBytes

(stream: Readable)

benchmarks/01-throughput.ts:46

↓ 4 callersFunctioncollectNodeStreamBytes

(stream: Readable)

benchmarks/11-fast-ws-throughput.ts:49

↓ 4 callersFunctioncollectWebStreamBytes

(stream: ReadableStream<Uint8Array>)

benchmarks/01-throughput.ts:24

↓ 4 callersFunctionconsumeNew

(readable: AsyncIterable<Uint8Array[]>)

benchmarks/20-memory-allocations.ts:77

↓ 4 callersFunctionconsumeNew

(readable: AsyncIterable<Uint8Array[]>)

benchmarks/21-memory-sustained.ts:80

↓ 4 callersFunctioncreateDirectStream

* Create a Bun Direct ReadableStream that yields one chunk per pull() call. * This mirrors the standard ReadableStream pull pattern but uses write()

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

↓ 4 callersMethodcreateRawConsumer

* Create a raw consumer iterable (internal helper).

src/share.ts:105

↓ 4 callersFunctioncreateWebUppercase

()

benchmarks/html/benchmarks.js:89

↓ 4 callersFunctioncreateZlibTransformObject

* Generic factory for creating zlib transform objects.

samples/14-compression.ts:256

↓ 4 callersMethoddrain

* Drain all buffered chunks into a single flat array.

src/push.ts:441

↓ 4 callersFunctionflattenTransformYieldAsync

* Flatten transform yield to Uint8Array chunks (async).

src/pull.ts:152

↓ 4 callersFunctionflattenTransformYieldAsync

* Flatten transform yield to Uint8Array chunks (async).

src/pull.js:198

↓ 4 callersFunctionfmt

(r: BenchmarkResult)

benchmarks/utils.ts:426

↓ 4 callersFunctiongenerateBatches

()

benchmarks/12-fast-ws-push-streams.ts:323

↓ 4 callersMethodgetMinCursor

* Get the slowest consumer's cursor position.

src/share.ts:364

↓ 4 callersMethodindexOf

* Find the logical index of `item` (reference equality). O(n). * Returns -1 if not found.

src/ringbuffer.ts:87

↓ 4 callersFunctionisPrimitiveChunk

* Check if value is a primitive chunk (string, ArrayBuffer, or ArrayBufferView).

src/from.js:97

↓ 4 callersFunctionisPrimitiveChunk

* Check if value is a primitive chunk (string, ArrayBuffer, or ArrayBufferView).

src/from.ts:37

↓ 4 callersFunctionisToStreamable

* Check if value implements ToStreamable protocol.

src/from.js:109

↓ 4 callersFunctionisToStreamable

* Check if value implements ToStreamable protocol.

src/from.ts:47

↓ 4 callersFunctionisTransformObject

* Check if a value is a TransformObject (has transform property).

src/pull.ts:51

↓ 4 callersFunctionisTransformObject

* Check if a value is a TransformObject (has transform property).

src/pull.js:104

↓ 4 callersFunctionprimitiveToUint8Array

* Convert a primitive chunk to Uint8Array. * - string: UTF-8 encoded * - ArrayBuffer: wrapped as Uint8Array view (no copy) * - ArrayBufferView: con

src/from.js:165

↓ 4 callersFunctionprimitiveToUint8Array

* Convert a primitive chunk to Uint8Array. * - string: UTF-8 encoded * - ArrayBuffer: wrapped as Uint8Array view (no copy) * - ArrayBufferView: con

src/from.ts:120

↓ 4 callersMethodpullFromSource

* Pull next chunk from source into buffer. * Returns a promise that resolves when the pull completes (or immediately if already pulling).

src/share.ts:304

↓ 4 callersMethodremoveAt

* Remove the item at logical `index`, shifting later elements. O(n) worst case. * Used only on rare abort-signal cancellation path.

src/ringbuffer.ts:100

↓ 4 callersMethodresolvePendingDrains

* Resolve all pending drains with a value.

src/broadcast.ts:638

↓ 4 callersFunctionresume

(n, v)

src/consumers.js:59

↓ 4 callersFunctionresume

(n, v)

src/from.js:54

↓ 4 callersFunctionresume

(n, v)

src/pull.js:63

↓ 4 callersFunctionsource

()

benchmarks/11-fast-ws-throughput.ts:505

↓ 4 callersFunctionstep

(result)

samples/util.js:7

↓ 4 callersFunctionstep

(result)

src/share.js:13

↓ 4 callersFunctionstep

(result)

src/duplex.js:13

↓ 4 callersFunctionstep

(result)

src/broadcast.js:13

↓ 4 callersFunctionstep

(result)

src/push.js:13

↓ 4 callersFunctiontoHex

(data: Uint8Array)

samples/15-encryption.ts:557

↓ 4 callersFunctionwebReadable

(chunks: Uint8Array[])

benchmarks/20-memory-allocations.ts:56

↓ 4 callersFunctionwebReadable

(data: Uint8Array[])

benchmarks/21-memory-sustained.ts:59

↓ 4 callersMethodwriteAsync

* Write chunks asynchronously. * - 'strict': Queues if buffer full but rejects if too many pending writes (>= highWaterMark) * - 'block': Waits

src/push.ts:237

↓ 4 callersMethodwriteSync

(chunk: Uint8Array | string)

samples/util.ts:52

↓ 3 callersFunctionbench

(name: string, fn: BenchFn, n: number)

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

↓ 3 callersFunctionbench

(name: string, fn: BenchFn, n: number)

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

↓ 3 callersFunctioncollect

(source: Iterable<Uint8Array[]>)

samples/16-pipeline-sync.ts:19

↓ 3 callersFunctioncollectBytes

Collect all bytes from a ReadableStream via reader.read() loop

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

↓ 3 callersFunctioncomputeSpeedup

(a: BenchmarkResult, b: BenchmarkResult)

benchmarks/utils.ts:372

↓ 3 callersFunctioncopyToBuffer

(chunk: Uint8Array)

samples/14-compression.ts:27

↓ 3 callersFunctioncreateIdentity

()

benchmarks/13-fast-ws-transforms.ts:416

↓ 3 callersFunctioncreateIdentity

()

benchmarks/04-pipelines.ts:318

↓ 3 callersFunctioncreateIdentity

()

benchmarks/03-transforms.ts:419

↓ 3 callersFunctioncreateIdentity

()

benchmarks/14-fast-ws-pipelines.ts:418

↓ 3 callersFunctioncreateTransform

()

benchmarks/04-pipelines.ts:281

↓ 3 callersFunctiondataSource

()

samples/03-branching.ts:76

↓ 3 callersFunctiondecode

(data: Uint8Array)

src/duplex.test.ts:14

↓ 3 callersFunctiondrainPending

()

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

↓ 3 callersMethodend

(_options?: WriteOptions)

samples/util.ts:67

↓ 3 callersMethodfailSync

Put writer into terminal error state synchronously. Returns false if writer cannot transition.

src/types.ts:200

↓ 3 callersFunctionformatRate

(bytes: number, ms: number)

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

↓ 3 callersFunctionformatRate

(bytes: number, ms: number)

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

↓ 3 callersFunctiongenerateBatches

()

benchmarks/02-push-streams.ts:256

↓ 3 callersFunctionisAsyncIterable

* Check if value is an async iterable (has Symbol.asyncIterator).

src/from.ts:83

↓ 3 callersFunctionisUint8ArrayBatch

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

src/pull.ts:356

← previous next →101–200 of 947, ranked by callers