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

↓ 1 callersFunctionapplyStatefulAsyncTransform

* Apply a single stateful async transform to a source.

src/pull.js:790

↓ 1 callersFunctionapplyStatefulSyncTransform

* Apply a single stateful sync transform to a source.

src/pull.ts:295

↓ 1 callersFunctionapplyStatefulSyncTransform

* Apply a single stateful sync transform to a source.

src/pull.js:529

↓ 1 callersFunctionapplyStatelessAsyncTransform

* Apply a single stateless async transform to a source.

src/pull.ts:365

↓ 1 callersFunctionapplyStatelessAsyncTransform

* Apply a single stateless async transform to a source.

src/pull.js:637

↓ 1 callersFunctionapplyStatelessSyncTransform

* Apply a single stateless sync transform to a source.

src/pull.ts:282

↓ 1 callersFunctionapplyStatelessSyncTransform

* Apply a single stateless sync transform to a source.

src/pull.js:504

↓ 1 callersFunctionasyncChunks

()

samples/01-basic-creation.ts:91

↓ 1 callersFunctionasyncGen

()

benchmarks/profile-bottlenecks.ts:54

↓ 1 callersFunctionasyncGen

()

benchmarks/profile-systematic.ts:52

↓ 1 callersFunctionasyncGen

()

benchmarks/profile-systematic2.ts:63

↓ 1 callersFunctionbadSource

()

samples/10-merging-concat.ts:206

↓ 1 callersFunctionbatchedAsyncGen

()

benchmarks/profile-bottlenecks.ts:64

↓ 1 callersFunctionbroadcast

(options?: BroadcastOptions)

src/broadcast.ts:769

↓ 1 callersMethodcancel

* Cancel all consumers and close source.

src/share.ts:560

↓ 1 callersFunctionchunkedEncode

(chunks: string[])

samples/10-merging-concat.ts:250

↓ 1 callersFunctioncleanup

()

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

↓ 1 callersFunctioncleanup

()

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

↓ 1 callersFunctioncollectSync

(source)

benchmarks/html/benchmarks.js:251

↓ 1 callersFunctioncombined

()

samples/10-merging-concat.ts:65

↓ 1 callersFunctioncompressGzip

()

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

↓ 1 callersFunctioncompressGzip

()

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

↓ 1 callersFunctionconcat

(...sources: AsyncIterable<T>[])

samples/10-merging-concat.ts:27

↓ 1 callersFunctioncountingGenerator

()

samples/02-consumption-methods.ts:104

↓ 1 callersFunctioncreateAes256CbcDecryptTransform

( key: Uint8Array, params: EncryptionParams )

samples/15-encryption.ts:302

↓ 1 callersFunctioncreateAes256CbcEncryptTransform

(key: Uint8Array)

samples/15-encryption.ts:227

↓ 1 callersFunctioncreateBatchTransformNewAPI

* Transform that batches input into 16KB chunks (New Streams API).

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

↓ 1 callersFunctioncreateBatchTransformWebStreams

* Transform that batches input into 16KB chunks (Web Streams).

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

↓ 1 callersFunctioncreateBrotliCompressTransform

(options?: zlib.BrotliOptions)

samples/14-compression.ts:364

↓ 1 callersFunctioncreateBrotliDecompressTransform

(options?: zlib.BrotliOptions)

samples/14-compression.ts:367

↓ 1 callersFunctioncreateBurstDirectStream

* Create a Bun Direct ReadableStream that writes ALL chunks in a single * pull() call. This is the "burst write" pattern — Direct RS's intended * sw

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

↓ 1 callersFunctioncreateChaCha20Poly1305DecryptTransform

( key: Uint8Array, params: EncryptionParams, aad?: Uint8Array )

samples/15-encryption.ts:464

↓ 1 callersFunctioncreateChaCha20Poly1305EncryptTransform

( key: Uint8Array, aad?: Uint8Array )

samples/15-encryption.ts:379

↓ 1 callersFunctioncreateCsvParser

()

samples/11-real-world-patterns.ts:85

↓ 1 callersFunctioncreateDeflateTransform

(options?: zlib.ZlibOptions)

samples/14-compression.ts:358

↓ 1 callersFunctioncreateFastWebStreamXor

()

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

↓ 1 callersFunctioncreateFixture

(size: number)

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

↓ 1 callersFunctioncreateFixture

(size: number)

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

↓ 1 callersFunctioncreateGunzipTransform

()

samples/15-encryption.ts:662

↓ 1 callersFunctioncreateGzipTransform

()

samples/15-encryption.ts:608

↓ 1 callersFunctioncreateGzipTransformStream

()

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

↓ 1 callersFunctioncreateHashTap

* Create a hash-logging tap transform. * * Stream.tap() is perfect for observation without branching: * - No separate consumer branch needed * - N

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

↓ 1 callersFunctioncreateInflateTransform

(options?: zlib.ZlibOptions)

samples/14-compression.ts:361

↓ 1 callersFunctioncreateJsonlParser

()

samples/11-real-world-patterns.ts:27

↓ 1 callersFunctioncreateLoremStreamNewAPI

* Generate lorem ipsum text using the new streams API.

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

↓ 1 callersFunctioncreateLoremStreamWebStreams

* Generate lorem ipsum text using Web Streams ReadableStream.

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

↓ 1 callersFunctioncreateNewStreamXor

()

benchmarks/04-pipelines.ts:122

↓ 1 callersFunctioncreateNewStreamXor

()

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

↓ 1 callersFunctioncreateNodeStreamXor

()

benchmarks/04-pipelines.ts:174

↓ 1 callersFunctioncreateNodeStreamXor

()

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

↓ 1 callersMethodcreateRawConsumer

* Create a raw consumer iterable (internal helper).

src/broadcast.ts:160

↓ 1 callersMethodcreateRawConsumer

* Create a raw consumer iterable (internal helper).

src/share.ts:437

↓ 1 callersFunctioncreateReadable

* Create the readable async iterable from a queue.

src/push.ts:670

↓ 1 callersFunctioncreateReadable

* Create the readable async iterable from a queue.

src/push.js:642

↓ 1 callersFunctioncreateSseParser

()

samples/11-real-world-patterns.ts:317

↓ 1 callersFunctioncreateWebStreamXor

()

benchmarks/04-pipelines.ts:143

↓ 1 callersFunctioncreateWebStreamXor

()

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

↓ 1 callersFunctiondataSource

()

samples/11-real-world-patterns.ts:492

↓ 1 callersFunctiondecryptMessage

(password: string, envelope: Uint8Array)

samples/15-encryption.ts:1109

↓ 1 callersFunctionencryptMessage

(password: string, plaintext: string)

samples/15-encryption.ts:1091

↓ 1 callersMethodend

()

samples/util.ts:117

↓ 1 callersMethodendSync

()

samples/util.ts:72

↓ 1 callersFunctionerrorSource

()

samples/09-resource-management.ts:406

↓ 1 callersFunctionerrorSource

()

samples/08-cancellation.ts:300

↓ 1 callersFunctionerrorSource

()

src/share.test.ts:239

↓ 1 callersFunctionerroringSource

()

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

↓ 1 callersMethodfail

(reason?: any)

src/broadcast.ts:713

↓ 1 callersMethodfail

(reason?: any)

src/push.ts:643

↓ 1 callersMethodfailSync

(reason?: any)

src/broadcast.ts:725

↓ 1 callersMethodfailSync

(reason?: any)

src/push.ts:648

↓ 1 callersFunctionfast

()

samples/10-merging-concat.ts:94

↓ 1 callersFunctionfileSource

()

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

↓ 1 callersFunctionfileSource

()

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

↓ 1 callersFunctionfileStream

(handle: FakeFileHandle)

samples/09-resource-management.ts:343

↓ 1 callersFunctionformatSize

(bytes: number)

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

↓ 1 callersFunctionformatSize

(bytes: number)

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

↓ 1 callersFunctionfrom

(input: ByteInput | Streamable)

src/from.ts:520

↓ 1 callersFunctiongenerateChunks

()

samples/01-basic-creation.ts:46

↓ 1 callersFunctiongenerateData

()

samples/14-compression.ts:487

↓ 1 callersFunctiongenerateData

(size: number)

benchmarks/utils.ts:526

↓ 1 callersFunctiongenerateJsonRecords

()

samples/14-compression.ts:751

↓ 1 callersFunctiongenerateLines

()

samples/14-compression.ts:424

↓ 1 callersFunctiongenerateRecords

()

samples/14-compression.ts:562

↓ 1 callersFunctiongenerateRecords

()

samples/15-encryption.ts:797

↓ 1 callersMethodgetAccessCount

()

samples/03-branching.ts:194

↓ 1 callersFunctiongetDecoder

(encoding: Encoding)

samples/14-compression.ts:696

↓ 1 callersFunctiongetEncoder

(encoding: Encoding)

samples/14-compression.ts:687

↓ 1 callersMethodgetMinCursor

* Get the slowest consumer's cursor position.

src/broadcast.ts:361

↓ 1 callersMethodgetMinCursor

* Get the slowest consumer's cursor position.

src/share.ts:615

↓ 1 callersFunctiongoodSource

()

samples/10-merging-concat.ts:200

↓ 1 callersFunctionhandleNewStreams

* Handle request using the new streams API. * * Optimizations over Web Streams approach: * 1. Generator-based source - no manual ReadableStream con

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

↓ 1 callersFunctionhandleWebStreams

* Handle request using Web Streams API.

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

↓ 1 callersFunctionhasCustomToString

* Check if object has a custom toString() (not Object.prototype.toString).

src/from.js:145

↓ 1 callersFunctionhasCustomToString

* Check if object has a custom toString() (not Object.prototype.toString).

src/from.ts:95

↓ 1 callersFunctionhasToPrimitive

* Check if object has Symbol.toPrimitive.

src/from.js:152

↓ 1 callersFunctionhasToPrimitive

* Check if object has Symbol.toPrimitive.

src/from.ts:103

↓ 1 callersFunctionhashBranchWebStreams

* Process a stream branch to generate hashes (Web Streams).

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

↓ 1 callersFunctionhttpResponse

()

samples/10-merging-concat.ts:301

↓ 1 callersFunctionisBroadcastable

* Check if value implements Broadcastable protocol.

src/broadcast.ts:797

↓ 1 callersFunctionisBroadcastable

* Check if value implements Broadcastable protocol.

src/broadcast.js:780

← previous next →301–400 of 947, ranked by callers