Awesome

RxPartialApplication2

RxPartialApplication is a library to allow partial application on RxJava function primitives.

For the RxJava 1.X version please go to RxPartialApplication.

Usage

RxPartialApplication2 contains two classes, RxPartialConsumer and RxPartialFunction. Each contains a set of apply() (apply parameters from left to right) and applyEnd() (apply parameters from right to left) methods to do partial application from any ConsumerN and FunctionN to any type of a lower arity. For example, you can partially apply a Function6 object with 3 prefilled parameters to obtain a Function3 object to be reused.

Function to multiply numbers by 100:

Function<Integer, Integer> multiplyBy100 = RxPartialFunction.apply((int first, int second) -> { return first * second; }, 100);
int result = multiplyBy100.call(5); // result == 500

Single parameter applicator:

Consumer<String> salutator = RxPartialConsumer.apply(applicator(), (String parameter) -> { System.out.println("Hello, " + parameter); } );
salutator.call("pakoito"); // prints "Hello, pakoito"
Consumer<Integer> duplicator = RxPartialFunction.apply(applicator(), (int parameter) -> { System.out.println("Double of parameter is " + 2 * parameter); } );
duplicator.call(2); // prints "Double of parameter is 4"

...

public static <T> BiConsumer<Action1<T>, T> applicator() {
    return (Action1<T> action, T parameter) -> { action.call(parameter); };
}

Filter only myself:

Function<Object, Boolean> isMe = RxPartialFunction.apply(equalsFilter(), myUser);
updatesFromDatabaseObservable().filter(isMe).map(toUser()).subscribe(/* ... */);

...

public static <T, U> BiFunction<T, U, Boolean> equalsFilter() {
    return (T first, U second) -> { return first.equals(second); };
}

You can also partially apply from the last parameter using applyEnd()

Function<String, Observable<String>>> requestForUrl =
        RxPartialFunction.applyEnd(this::doNetworkRequest(), localDataStorage, ServerInfo.default(), RetrofitRequest.getInstance());

requestForUrl.call("http://www.mycompany.com/api/users").subscribe(/* ... */);

Observable<String> doNetworkRequest(String url, DataStorage storage, ServerInformation server, HttpClient client){
  ...
}

Distribution

Add as a dependency to your build.gradle

repositories {
    ...
    maven { url "https://jitpack.io" }
    ...
}
    
dependencies {
    ...
    compile 'com.github.pakoito:RxPartialApplication2:1.0.0'
    ...
}

or to your pom.xml

<repositories>
    <repository>
        <id>jitpack.io</id>
        <url>https://jitpack.io</url>
    </repository>
</repositories>

<dependency>
    <groupId>com.github.pakoito</groupId>
    <artifactId>RxPartialApplication2</artifactId>
    <version>1.0.0</version>
</dependency>

License

The Apache Software License, Version 2.0

See LICENSE.md