README.md

CallbagKit › Documentation › Operators

Transforming

Operators that transform items that are emitted by a source.

• Indices: emit items with their indices from a source.

• Buffer: gather emitted items from a source by count or time factor, and emit these gathered items as an array.

• Collect: gather emitted items from a source upto a certain count, and emit these gathered items as an array.

• Codable: encode / decode data to a certain Encodable / Decodable type.

• Components: splits the emitted characters by a separator and emit these splitted characters as string.

• Split: splits the emitted values by a separator and emit these splitted values as array.

• Joined: emit a given item between emitted items from source.

• De-Materialize: represent both the items emitted and the completion sent as emitted items, or reverse this process.

• Map: applies a transformation on items passing through it.

• Compact: transform emitted items, and discard emitting nil items.

• FlatMap: transform the items emitted by a source into sources, then flatten the emissions from those into a single source.

• Pluck: map to object / dictionary properties.

• Group: divide a source into a set of sources that each emit a different subset of items from the original source.

• Partition: that splits the source into two, one with values that satisfy a predicate, and another with values that don't satisfy the predicate.

• Reduce: combine consecutive values into one value from the same source.

• Loop: accumulates results using a feedback loop that emits one value and feeds back another to be used in the next iteration.

• Scan: combines consecutive values from the same source. It's essentially like array .reduce, but delivers a new accumulated value for each value from the callbag source.

• Repeats: repeats/restarts the source stream by repeating the source handshake when source stream finished without error.

• Replace: replaces values with another ones in variate ways.