derekjw

import scalaz._,Scalaz._

import akka.scalaz.futures._
import akka.dispatch._

import System.{currentTimeMillis => now}

object Pi extends App {
  val nrOfElements = 10000
  val nrOfMessages = 10000

kevinwright

trait Constructable[T] {
  def construct: T
}

implicit object IntIsConstructable extends Constructable[Int] {
  def construct = 42
}

implicit object StringIsConstructable extends Constructable[String] {
  def construct = "Hello World"

oxbowlakes

<?xml version="1.0" encoding="UTF-8"?>
<scheme name="OxbowSolarizedDark" version="1" parent_scheme="Default">
  <option name="LINE_SPACING" value="1.2" />
  <option name="EDITOR_FONT_SIZE" value="13" />
  <option name="EDITOR_FONT_NAME" value="Consolas" />
  <colors>
    <option name="ADDED_LINES_COLOR" value="" />
    <option name="ANNOTATIONS_COLOR" value="2b36" />
    <option name="ANNOTATIONS_MERGED_COLOR" value="" />
    <option name="CARET_COLOR" value="dc322f" />

havocp

This quickstart will get you going with Scala and the twitter-finagle web library on the Cedar stack. Prerequisites

• Basic Scala knowledge, including an installed version of sbt 0.10.x and a JVM.
• Basic Git knowledge, including an installed version of Git.
• Your application must be compatible with sbt 0.10.1 or higher and scala 2.8.1.
• Your application must run on the OpenJDK version 6.
• An installed version of Ruby.

Install the Heroku Command-line Client

bdarfler

def benchmark(runs: Long, reps: Long, funct: => Any) = {     
    // warmup    
    println("Warming Up") 
    var i = 0
    while ( i < 25000 ) { funct; i = i + 1 }
    // test runs
    println("Running Test")
    var j = 0
    while ( j < runs ) {    
        var k = 0

overtone-1.clj

(ns test.core
  (:use [overtone.live]
        [overtone.inst.synth]))

(def kick  (sample "kick.wav"))
(def snare (sample "snare.wav"))
(def hit   (sample "hit.wav"))
(def insts {:kick  kick
            :snare snare
            :hit   hit})

daggerrz

package com.tapad.util

import akka.dispatch._
import java.util.concurrent.atomic.{AtomicInteger, AtomicBoolean}

class LogAndDiscardCircuitBreakerPolicy(val maxMailboxSize: Int, loggable: Logging) extends CircuitBreakerPolicy {
  def onOverflowStart(mailboxSize: Int) { loggable.log.warn("Mailbox size is above {}. Ignoring messages until size is back below.", maxMailboxSize) }
  def onBackToNormal(overflowCount: Int) { loggable.log.info("Mailbox size is back below {}. A total of {} messags were discarded.", maxMailboxSize, overflowCount) }

  def replyToOverflow(overflowCount: Int, msg: Any) : Either[Exception,  Any] = Left(new IllegalArgumentException("This overflow policy is not configured for request-reply actors."))

henrikengstrom

import akka.actor.{ Props, ActorSystem, Actor }
import akka.pattern.ask
import akka.util.Timeout
import akka.util.duration._
import akka.dispatch.Await
import util.Random

object DangerousOpTest extends App {
  println("starting system")
  val system = ActorSystem("daOp")

chrsan

package akka.unfiltered

import akka.actor._
import akka.dispatch.Future
import akka.pattern.ask
import akka.util.duration._
import akka.util.Timeout

import unfiltered.Async
import unfiltered.request._

marnix

trait BeeperDevice {
  def beep(beepSound: String)
}

trait DependsOnBeeper {
  protected val beeper: BeeperDevice
}


class Beeper extends BeeperDevice {