TouchInstinct
/
RxSwift
307
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add 'aggregate' function and spelling corrections.

This commit is contained in:
Daniel Tartaglia 2015-05-24 20:36:28 -04:00
parent 5de4a0fc88
commit 5de49b1d4d
1 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
OSXPlayground.playground/Contents.swift
View File

@ -135,7 +135,7 @@ var onlyEvensSubscriber = multipleObservable
This filter tracks the last value emitted and removes like values. This function is good for reducing noise in a sequence.
*/
let debugSubscriber = returnElements(1, 2, 3, 1, 1, 4)
let distinctUntilChangedSubscriber = returnElements(1, 2, 3, 1, 1, 4)
>- distinctUntilChanged
>- subscribeNext { value in
println("\(value)")
@ -143,8 +143,22 @@ let debugSubscriber = returnElements(1, 2, 3, 1, 1, 4)
/*:
In the example above, the values 1, 2, 3, 1, 4 will be printed. The extra 1 will be filtered out.
There are several different versions of `distinctUntilChanged`. Have a look in the file Observable+Single.swift to review them.
*/
/*:
## Aggregating a sequence
### `aggregate`
This function will perform a function on each element in the sequence until it is completed, then send a message with the aggregate value. It works much like the Swift `reduce` function works on sequences.
*/
let aggregateSubscriber = multipleObservable
>- aggregate(0, +)
>- subscribeNext { value in
println("\(value)")
}
/*:
To be continued...
*/