Fabien Chaillou fchaillou

David's programming examples knowledge base

Generated by code-examples-manager release 2.4.9-SNAPSHOT
659 published examples

akka-pekko

akka-actors-hello-world.sc : Simple akka hello world example
akka-capitalize-and-print.sc : dump capitalized string coming from stdin using streams
akka-http-client-json-stream.sc : Fully asynchronous http client call with json streamed response using akka-http will work in all cases, even with chunked responses !
akka-http-client-json-with-proxy.sc : Fully asynchronous http client call with json response using akka-http will work in all cases, even with chunked responses, this example add automatic http proxy support.
[akka-http-client-json.sc](https:/

Applied Functional Programming with Scala - Notes

1. Mastering Functions

A function is a mapping from one set, called a domain, to another set, called the codomain. A function associates every element in the domain with exactly one element in the codomain. In Scala, both domain and codomain are types.

val square : Int => Int = x => x * x

	import cats.effect.syntax.all.*
	import cats.syntax.all.*
	import cats.effect.*
	import fs2.Stream
	import cats.effect.std.Queue
	import scala.concurrent.duration.*

	import lib.FSM
	import lib.actor.{Actor, AskMsg}

	import play.api.libs.json.Json

	object Main{
	def main(args: Array[String]): Unit = {
	println(
	Json.prettyPrint(
	Json.toJson(Seq("Hello", "World", "Cow"))
	)
	)
	}

	% sbtx dependencyGraph
	... blah blah ...
	[info] * Welcome to the sbt build definition for Scala! *
	[info] Check README.md for more information.
	[error] Not a valid command: dependencyGraph
	[error] Not a valid project ID: dependencyGraph


	% sbtx -Dplugins=graph dependencyGraph
	... blah blah ...

	// Disable VirtualBox authentication
	VBoxManage setproperty websrvauthlibrary null

	// Start SOAP service so REX-Ray can talk to VirtualBox from the container host VMs
	/Applications/VirtualBox.app/Contents/MacOS/vboxwebsrv -H 0.0.0.0 -v

	// Create a Swarm cluster
	docker-machine create --driver=virtualbox default
	eval $(docker-machine env default)
	TOKEN=$(docker run --rm swarm create)

	package collector

	import akka.actor._
	import akka.util.Timeout
	import scala.concurrent.duration._
	import scala.concurrent.{Future, Promise}

	trait ResponseTracker[T] {
	def addResponse(response: T): ResponseTracker[T]
	def isDone: Boolean

	package stylewok.utils.writable;

	import org.apache.hadoop.io.*;

	import java.util.*;
	import java.io.*;

	public class UUIDToDoubleMapWritable extends HashMap<UUIDWritable,Double> implements Writable {
	public UUIDToDoubleMapWritable() { }

	import org.apache.hadoop.io.*;

	import java.util.*;
	import java.io.*;

	public class UUIDWritable implements WritableComparable<UUIDWritable> {
	private UUID value;

	public UUIDWritable(long mostSignificantBits, long leastSignificantBits) {
	value = new UUID(mostSignificantBits, leastSignificantBits);