Observable.sort

rx-sort.coffee

rx = require 'rx'
_ = require 'underscore'

Observable = rx.Observable

Observable::sort = (sorter) ->
	source = @
	Observable.createWithDisposable (observer) ->
		list = [];
		source.map((val) ->
			list.splice((index = sorter list, val), 0, val)
			index: index, value : val
		)
		.subscribe(observer)

randos = Observable.range(0, 100).map (-> Math.round(Math.random() * 1000))
sorted = randos.sort _.sortedIndex

sorted.subscribe console.log