7.1.0 Release of Cyclops

Stream enhandements

Scheduling Streams

Run a job every minute and log to the db once per day.

SequenceM.generate( () -> "new job")
                   .map(this::process)
                .schedule("0 * * * * ?", ex)
                .connect()
                .debounce(1,TimeUnit.DAYS)
                .forEach(this::logToDb);

Available as a static method in StreamUtils for JDK and java slang Streams

Stream for-comprehensions

Nested loops over multiple Streams

SequenceM.of(1,2,3)
                 .forEach2(a->IntStream.range(0,10), 
                         a->b-> a+b)
                 .toList()

//List[1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 2, 3, 4, 5, 6, 7, 8, 
                         9, 10, 11, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12)]

With the (optional) ability to filter

SequenceM.of(2,3)
                 .forEach3(a->IntStream.range(6,9),
                           a->b->IntStream.range(100,105),
                           a->b->c -> a==3,
                           a->b->c-> a+b+c)

//List[109, 110, 111, 112, 113, 110, 111, 112, 113, 114, 111, 112, 113, 114, 115]

Or use any monad type (via AnyM)

AnyM.streamOf(1,null,2,null,3)
                 .forEach2(a->AnyM.<Integer>fromOptional(Optional.ofNullable(a)), 
                         a->b-> a+b)

//AnyM[Stream[1,2,3]]

singleOptional operator

 //Optional[1]
SequenceM.of(1).singleOptional(); 

//Optional.empty
SequenceM.of().singleOpional();

//Optional.empty
SequenceM.of(1,2,3).singleOptional();

New Mutable methods and types

Mutable provides an API for encapsulated, or external, mutable values, for example, for mutating local variables inside Lambda Expressions.

New Mutable types

MutableBoolean
MutableByte
MutableShort
MutableFloat
MutableChar
MutableShort

Mutable<String> var =  Mutable.of("hello");
Runnable r = () -> var.set("world");

String value = "world";

Mutable<String> ext = Mutable.fromExternal(()->value,v->this.value=v);
ext.set("hello");

MutableFloat myFloat = new MutableFloat(zero);

      Function<Integer,Function<Integer,MutableFloat>> fn = ((Integer i)-> (Integer j)-> myFloatset(new Float((float)(i*j))));
      fn.apply(10).apply(20);

//myFloat 200       

Mutable<String> ext = Mutable.fromExternal(()->value,v->this.value=v)
                                    .mapInput(s->s+"!");
        ext.set("hello");

//value == "hello!"

New Monad Transformers

TryT
SetT

javadoc added for

OptionalT
StreamT
StreamableT
ListT
CompletableFutureT

Function<Integer,Integer> add2 = i -> i+2;
        Function<OptionalT<Integer>, OptionalT<Integer>> optTAdd2 = OptionalT.lift(add2);

        Stream<Integer> withNulls = Stream.of(1,2,null);
        AnyM<Integer> stream = AnyM.ofMonad(withNulls);
        AnyM<Optional<Integer>> streamOpt = stream.map(Optional::ofNullable);
        List<Integer> results = unwrapOptional(optTAdd2.apply(OptionalT.of(streamOpt)))
                                        .filter(Optional::isPresent)
                                        .map(Optional::get)
                                        .collect(Collectors.toList());

    //List(3,4);

New convertable mixin

Convertable.fromSupplier(()->null).orElse(11)
//11

Convertable.fromSupplier(()->10).toAtomicReference()

//AtomicReference[10]

Convertable.fromSupplier(()->10).toList()

//List(10)
etc.

Feature Tracking

Getting Cyclops 7.1.0

cyclops-all has all non-integration modules, but each module can be used / added individually (subject to it's own dependencies). Instructions for each module are in it's own readme.md.

Gradle

       compile 'com.aol.cyclops:cyclops-all:7.1.0'

Maven

     <dependency>
           <groupId>com.aol.cyclops</groupId>
           <artifactId>cyclops-all</artifactId>
           <version>7.1.0</version>
     </dependency>

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

v7.1.0 of Cyclops : Streams - Scheduling & for-comprehensions, singleOptional operator, new monad transformers, Mutable enhancements