mgandin

import java.io.IOException;

import de.flapdoodle.embed.mongo.MongodExecutable;
import de.flapdoodle.embed.mongo.MongodProcess;
import de.flapdoodle.embed.mongo.MongodStarter;
import de.flapdoodle.embed.mongo.config.MongodConfigBuilder;
import de.flapdoodle.embed.mongo.config.Net;
import de.flapdoodle.embed.mongo.distribution.Version;
import de.flapdoodle.embed.process.runtime.Network;

mgandin

package fr.mga.foobarqix;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

public class ConcurrentFooBarQix implements Callable<String> {

    private int toFooBar;

mgandin

package fr.mga.concurrent;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

public class ConcurrentFooBarQix implements Callable<String> {

mgandin

'use strict';
describe("HelloController", function() {

	var isTrue;
	var helloController;
	var scope;

	beforeEach(angular.mock.module('helloWorld.app'));

	beforeEach(angular.mock.inject(function($rootScope, $controller){

mgandin

package fr.mga.spike;

import java.util.concurrent.*;

public class ConcurrentFooBar {

    public static String fooBar(int anInteger) {
        String result = "";
        if (anInteger % 3 == 0)
            result += "foo";

mgandin

# -*- mode: ruby -*-
# vi: set ft=ruby :

VAGRANTFILE_API_VERSION = "2"

Vagrant.configure(VAGRANTFILE_API_VERSION) do |config|

  config.vm.define :ubuntu do |ubuntu|
     ubuntu.vm.box = "ubuntu"
     ubuntu.vm.network "private_network", ip: "10.11.12.13"

mgandin

package fr.mga.mashup;

import rx.Observable;

public class Hello {
    public String msg(String ... msg) {
        HelloFunction function = new HelloFunction();
        HelloReduce reduce = new HelloReduce();
        return Observable.from(msg).map(function).reduce(reduce).toBlocking().first();
    }

mgandin

package fr.mga.mashup.mapreduce;

import rx.Observable;

import java.util.List;

public class MapReduce {

    private List<Integer> list;

mgandin

package fr.mga.hello;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.context.annotation.ComponentScan;

@ComponentScan
@EnableAutoConfiguration
public class Application {

mgandin

package fr.mga.functional;

import java.util.HashMap;
import java.util.Map;

import static java.lang.Character.getNumericValue;
import static java.util.stream.Collectors.joining;

public class FooBar {