concurrency.stream.scan

Members

Functions

scan

auto scan(Stream stream, Fun scanFn, Seed seed)

Applies an accumulator to each value from the source

Templates

ScanStreamOp

template ScanStreamOp(Stream, Fun, Seed)

Undocumented in source.

• cron
• cycle
• defer
• filter
• flatmapbase
• flatmapconcat
• flatmaplatest
• sample
• scan
• slide
• stream
• take
• throttling
• tolist
• transform

• arrayStream
• doneStream
• errorStream
• infiniteStream
• intervalStream
• iotaStream
• sharedStream
• via

• SharedStream