/rx-clojure

RxJava bindings for Clojure

Primary LanguageClojure

rx-clojure

RxJava bindings for Clojure.

Installation

[org.clojars.vikasg7/rx-clojure "0.1.4-SNAPSHOT"]

Usage

Documentation

Examples

Notable differences from RxJava

  • Following operators are broken due to extensive method overloading.

    Original Broken into
    buffer buffer, bufferByBoundary, bufferByTime, bufferByTimeWithSkip, bufferByToggle
    window window, windowByBoundary, windowByTime, windowByTimeWithSkip, windowByToggle
    cacheWithInitialCapacity cache(initialCapacity)
    replay replay, replayWithBuffer
    takeLast takeLast, takeLastByTime
    timeout timeout, timeoutByIndicator

  • Added distinctUntilKeyChanged(keySelectorFunction) operator