Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/WinterTC55/iter-streams
/ functions
Functions
947 in github.com/WinterTC55/iter-streams
⨍
Functions
947
◇
Types & classes
113
↓ 1 callers
Function
isMergeOptions
* Check if last argument is MergeOptions.
src/consumers.js:87
↓ 1 callers
Function
isMergeOptions
* Check if last argument is MergeOptions.
src/consumers.ts:33
↓ 1 callers
Function
isOptions
* Detect if the last argument is options (object without 'transform' property).
src/push.ts:697
↓ 1 callers
Function
isOptions
* Detect if the last argument is options (object without 'transform' property).
src/push.js:680
↓ 1 callers
Function
isPullOptions
(value: unknown)
src/utils.ts:73
↓ 1 callers
Function
isPushStreamOptions
* Check if a value is PushStreamOptions (object without transform property).
src/broadcast.ts:47
↓ 1 callers
Function
isPushStreamOptions
* Check if a value is PushStreamOptions (object without transform property).
src/broadcast.js:81
↓ 1 callers
Function
isShareable
* Check if value implements Shareable protocol.
src/share.js:720
↓ 1 callers
Function
isShareable
* Check if value implements Shareable protocol.
src/share.ts:697
↓ 1 callers
Function
isSyncShareable
* Check if value implements SyncShareable protocol.
src/share.js:729
↓ 1 callers
Function
isSyncShareable
* Check if value implements SyncShareable protocol.
src/share.ts:709
↓ 1 callers
Function
isSyncTransformObject
* Check if a value is a SyncTransformObject.
src/pull.ts:63
↓ 1 callers
Function
isSyncTransformObject
* Check if a value is a SyncTransformObject.
src/pull.js:113
↓ 1 callers
Function
isSyncUint8ArrayBatch
* Check if value is already a Uint8Array[] batch (fast path check for sync).
src/from.js:273
↓ 1 callers
Function
isSyncUint8ArrayBatch
* Check if value is already a Uint8Array[] batch (fast path check for sync).
src/from.ts:221
↓ 1 callers
Function
largeSource
()
samples/11-real-world-patterns.ts:221
↓ 1 callers
Function
lines
()
samples/01-basic-creation.ts:80
↓ 1 callers
Function
main
()
samples/17-duplex-channels.ts:19
↓ 1 callers
Function
main
()
samples/01-basic-creation.ts:11
↓ 1 callers
Function
main
()
samples/09-resource-management.ts:19
↓ 1 callers
Function
main
()
samples/10-merging-concat.ts:19
↓ 1 callers
Function
main
()
samples/13-web-streams-interop.ts:227
↓ 1 callers
Function
main
()
samples/14-compression.ts:374
↓ 1 callers
Function
main
()
samples/11-real-world-patterns.ts:14
↓ 1 callers
Function
main
()
samples/02-consumption-methods.ts:13
↓ 1 callers
Function
main
()
samples/15-encryption.ts:565
↓ 1 callers
Function
main
()
samples/03-branching.ts:14
↓ 1 callers
Function
main
()
samples/05-piping.ts:14
↓ 1 callers
Function
main
()
samples/04-transforms.ts:14
↓ 1 callers
Function
main
()
samples/06-buffer-configuration.ts:14
↓ 1 callers
Function
main
()
samples/08-cancellation.ts:15
↓ 1 callers
Function
main
()
samples/07-encoding.ts:15
↓ 1 callers
Function
main
()
samples/16-pipeline-sync.ts:32
↓ 1 callers
Function
main
()
samples/12-nodejs-interop.ts:262
↓ 1 callers
Function
main
()
benchmarks/run-all.ts:33
↓ 1 callers
Function
main
()
benchmarks/21-memory-sustained.ts:264
↓ 1 callers
Function
main
()
benchmarks/profile-bottlenecks.ts:27
↓ 1 callers
Function
main
()
benchmarks/profile-systematic.ts:27
↓ 1 callers
Function
main
()
benchmarks/profile-systematic2.ts:27
↓ 1 callers
Function
multipartBody
()
samples/10-merging-concat.ts:229
↓ 1 callers
Function
normalizeSyncSource
* Normalize a sync streamable source, yielding batches of Uint8Array. * * @param source - The sync streamable source * @yields Uint8Array[] batches
src/from.ts:234
↓ 1 callers
Function
normalizeSyncValue
* Normalize a sync streamable yield value to Uint8Array chunks. * Recursively flattens arrays, iterables, and protocol conversions. * * @yields Uin
src/from.js:208
↓ 1 callers
Function
normalizeSyncValue
* Normalize a sync streamable yield value to Uint8Array chunks. * Recursively flattens arrays, iterables, and protocol conversions. * * @yields Uin
src/from.ts:170
↓ 1 callers
Function
nullWriter
()
benchmarks/20-memory-allocations.ts:85
↓ 1 callers
Function
nullWriter
()
benchmarks/21-memory-sustained.ts:88
↓ 1 callers
Function
parseArgs
* Parse variadic arguments: [...transforms, options?]
src/push.ts:708
↓ 1 callers
Function
parseArgs
* Parse variadic arguments: [...transforms, options?]
src/push.js:688
↓ 1 callers
Function
parsePushArgs
* Parse variadic arguments for push(). * Returns { transforms, options }
src/broadcast.ts:60
↓ 1 callers
Function
parsePushArgs
* Parse variadic arguments for push(). * Returns { transforms, options }
src/broadcast.js:91
↓ 1 callers
Function
part1
()
samples/10-merging-concat.ts:53
↓ 1 callers
Function
part2
()
samples/10-merging-concat.ts:59
↓ 1 callers
Function
printComparison
(comparisons: BenchmarkComparison[])
benchmarks/utils.ts:273
↓ 1 callers
Function
printComparisonTable
* Print a single comparison table with the given column headers and rows.
benchmarks/utils.ts:234
↓ 1 callers
Function
printResults
(title: string, results: [SustainedResult, SustainedResult][])
benchmarks/21-memory-sustained.ts:221
↓ 1 callers
Function
printSingleResults
* Print a single benchmark result for non-comparison tests.
benchmarks/10-advanced-features.ts:28
↓ 1 callers
Function
processTransformResultSync
* Process transform result (sync).
src/pull.ts:183
↓ 1 callers
Function
processTransformResultSync
* Process transform result (sync).
src/pull.js:285
↓ 1 callers
Function
processor
()
samples/11-real-world-patterns.ts:437
↓ 1 callers
Method
resolvePendingWrites
* Resolve pending writes when buffer has space.
src/broadcast.ts:609
↓ 1 callers
Function
runBenchmark
(file: string)
benchmarks/run-all.ts:14
↓ 1 callers
Function
runBenchmarks
()
benchmarks/13-fast-ws-transforms.ts:26
↓ 1 callers
Function
runBenchmarks
()
benchmarks/01-throughput.ts:70
↓ 1 callers
Function
runBenchmarks
()
benchmarks/08-pipeline-sync.ts:172
↓ 1 callers
Function
runBenchmarks
()
benchmarks/04-pipelines.ts:20
↓ 1 callers
Function
runBenchmarks
()
benchmarks/10-advanced-features.ts:49
↓ 1 callers
Function
runBenchmarks
()
benchmarks/03-transforms.ts:21
↓ 1 callers
Function
runBenchmarks
()
benchmarks/09-sync-async-comparison.ts:87
↓ 1 callers
Function
runBenchmarks
()
benchmarks/14-fast-ws-pipelines.ts:27
↓ 1 callers
Function
runBenchmarks
()
benchmarks/07-sync-generators.ts:17
↓ 1 callers
Function
runBenchmarks
()
benchmarks/16-fast-ws-consumption.ts:24
↓ 1 callers
Function
runBenchmarks
()
benchmarks/12-fast-ws-push-streams.ts:24
↓ 1 callers
Function
runBenchmarks
()
benchmarks/17-bun-direct-streams.ts:197
↓ 1 callers
Function
runBenchmarks
()
benchmarks/02-push-streams.ts:20
↓ 1 callers
Function
runBenchmarks
()
benchmarks/11-fast-ws-throughput.ts:73
↓ 1 callers
Function
runBenchmarks
()
benchmarks/05-tee-branching.ts:21
↓ 1 callers
Function
runBenchmarks
()
benchmarks/06-consumption.ts:20
↓ 1 callers
Function
runBenchmarks
()
benchmarks/15-fast-ws-tee-branching.ts:28
↓ 1 callers
Function
settle
(resolve, reject, d, v)
src/broadcast.js:49
↓ 1 callers
Function
share
( source: AsyncIterable<Uint8Array[]> | Iterable<Uint8Array[]>, options?: ShareOptions )
src/share.ts:649
↓ 1 callers
Function
shareSync
( source: Iterable<Uint8Array[]>, options?: ShareSyncOptions )
src/share.ts:682
↓ 1 callers
Function
slow
()
samples/10-merging-concat.ts:102
↓ 1 callers
Function
slowSource
()
samples/09-resource-management.ts:241
↓ 1 callers
Function
slowSource
()
samples/05-piping.ts:92
↓ 1 callers
Function
slowSource
()
src/share.test.ts:134
↓ 1 callers
Function
source
()
samples/11-real-world-patterns.ts:440
↓ 1 callers
Function
source
()
samples/06-buffer-configuration.ts:258
↓ 1 callers
Function
source
()
samples/08-cancellation.ts:262
↓ 1 callers
Function
source
()
samples/12-nodejs-interop.ts:422
↓ 1 callers
Function
source
()
src/share.test.ts:327
↓ 1 callers
Function
source
()
benchmarks/17-bun-direct-streams.ts:318
↓ 1 callers
Function
source1
()
samples/08-cancellation.ts:355
↓ 1 callers
Function
source2
()
samples/08-cancellation.ts:362
↓ 1 callers
Function
source3
()
samples/10-merging-concat.ts:332
↓ 1 callers
Function
stdDev
* Calculate standard deviation
benchmarks/utils.ts:60
↓ 1 callers
Function
step
(op)
src/ringbuffer.js:6
↓ 1 callers
Function
syncConcat
()
samples/10-merging-concat.ts:76
↓ 1 callers
Function
syncDataSource
()
samples/03-branching.ts:106
↓ 1 callers
Function
syncGen
()
benchmarks/profile-bottlenecks.ts:45
↓ 1 callers
Function
syncGen
()
benchmarks/profile-systematic.ts:61
↓ 1 callers
Function
syncGen
()
benchmarks/profile-systematic2.ts:72
← previous
next →
401–500 of 947, ranked by callers