timyates

@Grab( 'com.google.guava:guava:16.0.1' )
import static com.google.common.base.CaseFormat.*
 
String.metaClass.caseFormat = { from, to ->
  from.to( to, delegate )
}
 
// From camelCase (LOWER_CAMEL) to SNAKE_CASE (UPPER_UNDERSCORE)
assert 'varName'.caseFormat( LOWER_CAMEL, UPPER_UNDERSCORE )       == 'VAR_NAME'

timyates

In the current groovy-stream master branch (0.8), I'm adding Java support.

Say you have two lists, [1, 2, 3] and [4, 5, 6] and you want to print all the sums of these numbers that are odd.

You can now do this in Java 1.6+

Map<String,List<Integer>> map = new HashMap<String,List<Integer>>() {{
    put( "x", Arrays.asList( 1, 2, 3 ) ) ;
    put( "y", Arrays.asList( 4, 5, 6 ) ) ;

timyates

Stream.from( x:[1,2,3], y:[4,5,6] )
      .map { x + y }
      .filter { it % 2 }
      .each { println it }

timyates

@Grab( 'com.netflix.rxjava:rxjava-groovy:0.17.1' )
import rx.Observable
import rx.Observer
import rx.subscriptions.Subscriptions

def fibObs = Observable.create { Observer<BigInteger> observer ->
    Thread t
    t = Thread.start {
        def prev = 0G
        def next = 0G

timyates

@Grab( 'com.netflix.rxjava:rxjava-groovy:0.17.1' )
import rx.*
import rx.schedulers.*
import java.util.concurrent.TimeUnit

// Emit the date every second
def date = Observable.create { observer ->
    Schedulers.newThread().schedulePeriodically( { inner ->
        observer.onNext( new Date() )
    }, 0, 1000, TimeUnit.MILLISECONDS )

timyates

Based on the Ruby version here, blogged about here by @otobrglez

timyates

import groovy.transform.*
import groovyx.gpars.actor.*
import groovyx.gpars.group.*

@Immutable class Calculate {}
@Immutable class Work { int start, nrOfElements }
@Immutable class Result { double value }
@Immutable class PiApproximation { double pi ; long duration }

double calculatePiFor( int start, int nrOfElements ) {

timyates

package test;

import java.math.BigInteger;
import java.util.function.Function;

public class YCombinatorFactorial<T> {
    private interface Improver<T> {
        Function<T,T> apply( Improver<T> f ) ;
    }

timyates

import java.util.Random;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.LongAdder;
import java.util.stream.IntStream;

public class LongAdderTest {
    ConcurrentHashMap<Integer,LongAdder> frequencyMap = new ConcurrentHashMap<>() ;
    Random rnd = new Random() ;

    void run() {

timyates

##New stuff in Java 1.7

Method or Field: java.applet.Applet.isValidateRoot

Method or Field: java.awt.Component.revalidate

Method or Field: java.awt.Container.isValidateRoot

Method or Field: java.awt.event.InvocationEvent.isDispatched