Josh Hesketh aphexmunky

If your csv doesn't contain escaped newlines then it is pretty easy to do a progressive parsing without putting the whole file into memory. The iteratee library comes with a method search inside play.api.libs.iteratee.Parsing :

def search (needle: Array[Byte]): Enumeratee[Array[Byte], MatchInfo[Array[Byte]]]

which will partition your stream into Matched[Array[Byte]] and Unmatched[Array[Byte]]

Then you can combine a first iteratee that takes a header and another that will fold into the umatched results. This should look like the following code:

// break at each match and concat unmatches and drop the last received element (the match)

Backend Architectures

Twitter

ror, scala, jetty, erlang, thrift, mongrel, comet server, my-sql, memchached, varnish, kestrel(mq), starling, gizzard, cassandra, hadoop, vertica, munin, nagios, awstats

Introduce Gizzard of Twitter - 트위터의 새로운 분산 관리 라이브러리 Gizzard를 소개합니다.
The Architecture Twitter Uses to Deal with 150M Active Users, 300K QPS, a 22 MB/S Firehose, and Send Tweets in Under 5 Seconds
Scaling Twitter: Making Twitter 10000 Percent Faster

The introduction to Reactive Programming you've been missing

(by @andrestaltz)

This tutorial as a series of videos

If you prefer to watch video tutorials with live-coding, then check out this series I recorded with the same contents as in this article: Egghead.io - Introduction to Reactive Programming.

Steps for firing up a full Avalanche node

Avalanche is an open-source platform for launching highly decentralized applications, financial primitives, and interoperable blockchains.

These are steps for firing up an Avalanche full node on Digital Ocean.

Digital Ocean Ubuntu Instance

ssh into a Digital Ocean Ubuntu box

	//this runs the dependencies in parallel (undesirable)
	buildAndRun <<= Seq(addScalaLib, packageDebug in Android, removeScalaLib, startDevice in Android).dependOn,

	---- vs ---

	//this runs the dependencies serially (desired)
	buildAndRun <<= removeScalaLib,
	buildAndRun <<= buildAndRun dependsOn (startDevice in Android),
	buildAndRun <<= buildAndRun dependsOn (packageDebug in Android),
	buildAndRun <<= buildAndRun dependsOn addScalaLib,

	package akkahttptest

	import akka.http.Http
	import akka.stream.ActorFlowMaterializer
	import akka.actor.ActorSystem
	import akka.stream.scaladsl.{Sink, Source}
	import akka.http.model._

	object TestClient extends App {

	package main
	import (
	"./binding"
	"fmt"
	)

	func main() {
	binding.PrintHello()
	binding.Seed(1)
	fmt.Println(binding.Random())

	#!groovy
	# Best of Jenkinsfile
	# `Jenkinsfile` is a groovy script DSL for defining CI/CD workflows for Jenkins
	node {
	}