Dominic Bou-Samra dbousamra

dbousamra / Example2.scala

Created June 9, 2017 04:24

	object Example {

	def process(implicit strat: Strategy): Sink[Task, List[Int]] = { ms =>
	ms.evalMap { i =>
	Task {
	println(s"In consumer length ${i.length}")
	Thread.sleep(200)
	}
	}
	}

dbousamra / Example.scala

Last active June 9, 2017 03:24

	object Example {
	def main(args: Array[String]): Unit = {


	implicit val strat = fs2.Strategy.fromCachedDaemonPool()

	val ms: Stream[Task, String] = Stream.eval {
	Task {
	println("Evaluating message stream")
	Thread.sleep(1000)

dbousamra / Example.scala

Created June 8, 2017 07:18

	object Example {
	def messageStream(client: AmazonSQSAsyncClient, request: ReceiveMessageRequest)(implicit s: Strategy): Stream[Task, Message] = {
	Stream.repeatEval(AsyncSQS.getMessagesAsync(client, request)).flatMap { result =>
	Stream.emits(result.getMessages.asScala)
	}
	}

	def batchPipe(n: Int): Pipe[Task, Message, List[Message]] = { messages =>
	messages.vectorChunkN(n, true).map(_.toList)
	}

dbousamra / Generators.scala

Created May 30, 2017 07:51

	case class Gen[A](g: () => A) {

	/*
	* Evaluates a Gen, yielding a value
	*/
	def sample: A = {
	g()
	}

	/*

dbousamra / ArgonautPrettyErrors.scala

Created May 16, 2017 00:37

	import argonaut._
	import Argonaut._
	import argonaut.CursorOpDownArray

	case class Job(name: String, salary: Option[Int])

	case class Person(name: String, job: Job)

	object Person {

dbousamra / async.js

Last active April 17, 2017 04:36

	var sumAsync = function(a, b, callback) {
	sleep(1000)
	return callback(a + b);
	}

dbousamra / pokemon.json

Created February 12, 2017 05:35

	{
	"name":"water",
	"generation":{
	"url":"http:\/\/pokeapi.co\/api\/v2\/generation\/1\/",
	"name":"generation-i"
	},
	"damage_relations":{
	"half_damage_from":[
	{
	"url":"http:\/\/pokeapi.co\/api\/v2\/type\/9\/",

dbousamra / Example.scala

Last active December 24, 2016 06:34

	object Example {
	def main(args: Array[String]): Unit = {
	val messages: Stream[fs2.Task, Int] = Stream.constant[fs2.Task, Int](1).repeat
	val process: Pipe[fs2.Task, Int, String] = _.evalMap { m =>
	FS2Helpers.task2fs2Task(scalaz.concurrent.Task.now(m.toString)) // now, oddly, if this is Task { ... } instead of now(..) it works fine
	}
	val pipeline = messages.through(process)
	pipeline.run.unsafeRun()
	}
	}

dbousamra / DataDogMetrics.scala

Created December 12, 2016 04:59

dbousamra / Basics.md

Created November 29, 2016 23:05

Http4s Basics