cyclops-integration
cyclops-integration copied to clipboard
aol
Home of the cyclops integration modules : support for Scala, Clojure, RxJava (1+2), Reactor, FunctionalJava, Guava, Dexx & Vavr
How to throw exception if one of the operations faile ``` Try request = Try.withCatch(() -> Convertor.fromJsonToPojo(payload, PepRequest.class)) .onFail(e -> LOG.error("failed to serialize Json payload:{} exception:{}",payload, e)) .map(pepReq -> (new...
When i want to try like as follows Try.witchCatch(()->a()).onFail().map(()->b()).. where b() throws an exception as well, it says b with unhandled exception, who do deal in such situation? we can...
Can you please share any example of how to use ReaderT monad transformer like below Scala example gist? https://gist.github.com/noorulhaq/d620f750eafb0e9cd8496ce99b52ac2e The objective is to avoid extra map required for extracting value...
Hi, I tried chaining below operations ```java OptionalTValue valueT1 = OptionalT.fromValue(Try.of(Optional.of("Noor1"))); OptionalTValue valueT2 = OptionalT.fromValue(Try.failure(new RuntimeException("ERROR"))); System.out.println(valueT1.flatMapT(i-> valueT2.map(j -> i.concat(j)))); ``` And it prints below string instead of OptionalTValue[AnyMValue[Failure]] OptionalTValue[AnyMValue[]]...
Create a set of conditional converters making use of coflatMap (see https://github.com/aol/cyclops-react/issues/398) to either unwrap or convert to underlying type
* jmh benchmarks should compare performance of lazy / eager collection features * ensure /demonstrate performance of ReactiveSeq comparable to java.util.stream.Stream * LazyFutureStream for I/O operations
Provide a Guava specific API / view into cyclops-react's FluentFunctions api that builds in Guava caching for memorization
Caching within a stream with Guava caching.
Paguro is a port of the core Clojure collections api. A PVectorX implementation backed by Paguro would be faster than one backed by pCollections ( BitmappedVectorTrie cf IntTreeMap)