djspiewak

#!/usr/bin/ruby

require 'json'

DESC_HEAD = /^\.([^\.\[]+)/
DEREF_HEAD = /^\[(\d+)\]/

def usage
  $stderr.puts <<USAGE
usage: json descriptor

aphyr

#!/usr/bin/env ruby

# Synchronizes ZFS filesystems.
#
# Takes three args: source pool, destination pool, and filesystem name.
#
# Syncs most recent snapshot of filesystem from source to destination pool,
# using incremental transfer if possible.

# Take a snapshot line from zfs list -t snapshot and emit a struct

djspiewak

package com.rr.experiment

import org.specs2.ScalaCheck
import org.specs2.mutable._

import org.scalacheck._

import scalaz._

import scodec._

djspiewak

Reading SBT Credentials from OS X Keychain

In the following, replace the REPO_NAME value with the natural-language name of your repository, replace REPOSITORY with the domain name (e.g. repo1.maven.org) and replace USERNAME with your repository user.

credentials += {
  val Password = """.*password: "([^"]+)".*""".r
  var lines: String = ""
  val logger = new ProcessLogger {
 def info(s: => String) = {}

kevinwright

As compiled by Kevin Wright a.k.a @thecoda

(executive producer of the movie, and I didn't even know it... clever huh?)

please, please, please - If you know of any slides/code/whatever not on here, then ping me on twitter or comment this Gist!

This gist will be updated as and when I find new information. So it's probably best not to fork it, or you'll miss the updates!

Monday June 16th

rbuckland

package com.soqqo.luap.messages

import com.soqqo.luap.messages.ContextMetaData
import com.soqqo.luap.messages.NoContextMetaData
import com.soqqo.luap.messages.RegisterNewPerson
import io.straight.fw.model.Uuid
import scala.reflect.api.JavaUniverse
import scala.reflect.api
import io.straight.fw.jackson.JacksonBindingSupport._
import scala.Some

mnadel

import org.apache.commons.lang3.Validate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.concurrent.Callable;

/**
 * A database session and transaction-aware Callable
 */
class DatabaseCallable<T> implements Callable<T>

ryanlecompte

import java.io.File

/**
 * Iterate all files in the given directory recursively.
 * @param root the root directory to traverse
 * @return an Iterator[File] of traversed files
 */
def listFiles(root: File): Iterator[File] = {
  def rec(files: List[File]): Stream[File] = {
    files match {

jboner

# How Akka maps to EAI Patterns

Might be up for debate or just plain wrong. Just some notes I scribbled down some time ago. 

-----------------------------------------------------------------------------------------------------------------
EAI PATTERN                     AKKA PATTERN                  REFERENCE
-----------------------------------------------------------------------------------------------------------------
Point to Point Channel          Regular Actor Communication   http://www.eaipatterns.com/PointToPointChannel.html
Event-Driven Consumer           Regular Actor Receive         http://www.eaipatterns.com/EventDrivenConsumer.html
Message Selector                Actor with Stash              http://www.eaipatterns.com/MessageSelector.html

ericacm

package akka.contrib.pattern

import akka.actor.{Cancellable, ActorLogging, ActorRef, Actor}
import java.util
import akka.serialization.SerializationExtension
import scala.concurrent.ExecutionContext
import scala.concurrent.duration._
import scala.util.{Try, Failure, Success}
import scala.language.existentials
import java.util.UUID