example: race.

examples/index.ts

@@ -3,5 +3,6 @@ import './cycle'
 import './debugging'
 import './delay'
 import './event-emitter'
+import './race'
 import './reduce'
 import './set-interval'

examples/race.ts

@@ -0,0 +1,41 @@
+console.info('example: race')
+
+import { Bud } from 'fluh'
+import { Bud as T_Bud } from 'fluh/lib/Bud'
+
+import transfer from 'fluh/lib/transfer'
+
+import { every } from 'fluh/thru/promise'
+import { last } from 'fluh/thru/promise'
+import { buffered } from 'fluh/thru/promise'
+
+function delay (bud: T_Bud<number>) {
+	return transfer(bud, (value, emit) => {
+		const timeout = (10 - value)
+		emit(new Promise(rs => {
+			setTimeout(() => rs(value), (timeout * 25))
+		}))
+	})
+}
+
+const source = Bud<number>()
+const delayed = source.thru(delay)
+
+const delayed_every = delayed.thru(every)
+const delayed_last = delayed.thru(last)
+const delayed_buffered = delayed.thru(buffered(3))
+
+delayed_every.on(n =>    console.log('   EVERY', n))
+delayed_last.on(n =>     console.log('    LAST', n))
+delayed_buffered.on(n => console.log('BUFFERED', n))
+
+source
+.emit(1)
+.emit(2)
+.emit(3)
+.emit(4)
+.emit(5)
+.emit(6)
+.emit(7)
+.emit(8)
+.emit(9)