akarnokd / ixjava Goto Github PK

Iterable Extensions for Java 6+

License: Apache License 2.0

CSS 0.40% Java 99.32% Shell 0.28%

iterable-extensions stream java rxjava iterable

ixjava's Introduction

ixjava

Iterable Extensions for Java, the dual of RxJava. Originally implemented in the Reactive4Java framework, now standalone; no dependencies on any reactive library.

The aim is to provide, lazily evaluated, pull-based datastream support with the same naming as in RxJava mainly for the pre-Java-8 world. The Stream API in Java 8 is not exactly the same thing because Streams can be only consumed once while Iterables can be consumed many times. Google Guava features a lot of Iterable operators, plus now they have the FluentIterable with similar setup but far less operators available.

This branch starts from scratch by reimplementing ix.Ix and all of its operators based on the +5 year experience with reactive and interactive dataflows.

Releases

Javadoc: https://akarnokd.github.io/ixjava/javadoc/index.html

gradle

dependencies {
    implementation 'com.github.akarnokd:ixjava:1.0.0'
}

Maven search:

http://search.maven.org

Examples

The main (and only) entry point is the class ix.Ix which features a bunch of static factory methods:

List<Integer> list = Arrays.asList(1, 2, 3, 4, 5);

Ix<Integer> seq = Ix.from(list);

Now we can apply instance methods on the seq sequence, just like in RxJava. Not all operators are available though due to the synchronous-pull nature of IxJava.

seq
.map(v -> v + 1)
.filter(v -> v % 2 == 0)
.flatMap(v -> Ix.fromArray(v * 10, v * 100)))
.subscribe(System.out::println)
;

Since Ix implements Iterable, you can use the for-each loop to consume it:

for (Integer v : Ix.fromArray(5, 10).skip(1).concatWith(Ix.just(20))) {
    System.out.println("Value: " + v);
}

For further details on the possibilities, please study the javadoc of Ix.

ixjava's People

Contributors

Stargazers

Watchers

Forkers

xgrommx bryant1410 renzhan nfekete dkhmelenko russllgo87

ixjava's Issues

[Security] Workflow gradle-wrapper-validation.yml is using vulnerable action gradle/wrapper-validation-action

The workflow gradle-wrapper-validation.yml is referencing action gradle/wrapper-validation-action using references v1. However this reference is missing the commit 89eda1fdc0167f59521d2bb10767f7169fb4d018 which may contain fix to the some vulnerability.
The vulnerability fix that is missing by actions version could be related to:
(1) CVE fix
(2) upgrade of vulnerable dependency
(3) fix to secret leak and others.
Please consider to update the reference to the action.

Split a Collection into 2 lists and subscribe both?

My use case is as follow:

A collection of Box as source: boxes.
There are red boxes and blue boxes in source.
Once I "press the button" (start the stream), it will split the boxes into 2 lists by box's color, and I could subscribe to the value contain both of them.

My imagine is as follow (seudo):

Ix.from(source)
.split((predicate) -> predicate.apply(box) /* return true if box is red, false otherwise*/)
.subscribe((redBoxes, blueBoxes) -> { /* do something, maybe share them with friends */})

How can I archive this behaviour with your current implementation? If it is not possible now, any opinion on why and how?

P/S: I know about the "except" operator. But it ends up creating extra Collection which I want to avoid.

Thanks.

Bring This Under ReativeX umbrella

Can this be moved under the ReactiveX umbrella? Also Reactor can make do with a similar API.

Sync operators with RxJava/Rsc

IxJava is a bit behind some operators. This issue will collect these into a checklist:

concatMap
subscribe(Action1) - alternative to forEach due to name conflict in Java 8
subscribe(Observer) - to feed a regular Observer with the same naming pattern

Thanks and best regards from Switzerland,
Peti

Why there is not skip method?

It looks like there is skipLast method only.
It is on purpose?