richdougherty

autoCompilerPlugins := true,
libraryDependencies <+= scalaVersion {
  v => compilerPlugin(
    "org.scala-lang.plugins" %
    "continuations" %
    "2.10.0-RC5")
    // Use the final Scala version once it's released
},
scalacOptions += "-P:continuations:enable",

richdougherty

public Future<List<String>> crawl(final String url, final int maxDepth, final int currentDepth) {
  if (maxDepth == currentDepth) {
    // no need to call
    return Future.succesful(Collections.emptyList());
  } else {

    // 1. get crawl the URL and get its URLs

    Future<List<String>> foundUrlsFuture = future(new Callable<List<String>>() {
      public List<String> call() throws Exception {

richdougherty

import play.api._

import com.typesafe.config.ConfigFactory
import akka.actor.ActorSystem

object Global extends GlobalSettings {
  override def onStart(app: Application) {
    val config = ConfigFactory.parseString("""
akka {
  actor {

richdougherty

import org.specs2.mutable.Specification
import org.specs2.runner.JUnitRunner
import org.junit.runner.RunWith

@RunWith(classOf[JUnitRunner])
class MySpec extends Specification {
  "The number 1" should {
    "equal the number 2" in {
      1 must_== 2
    }

richdougherty

    implicit val system = ActorSystem("jse-system")
    implicit val timeout = Timeout(5.seconds)

    val engine = system.actorOf(Rhino.props(), "engine")

    def tempResourceFile(resourceName: String): File = {
      import org.apache.commons.io._
      val url = this.getClass.getResource(resourceName);
      val file = File.createTempFile(
              FilenameUtils.getBaseName(resourceName),

richdougherty

  val PlayBaseDirProp = Tags.Tag("PlayBaseDirProp")
  concurrentRestrictions in Global += Tags.limit(PlayBaseDirProp, 1)

  def withSystemProperty[T](name: String, value: String)(f: => T) = {
    println(s"*** Setting property $name = $value")
    System.setProperty(name, value)
    try {
      f
    } finally {
      println(s"*** Clearing property $name")

richdougherty

macro invert {
  rule { { $x:ident <- $y:expr } } => {
    $y(function($x) { return $x })
  }
  rule { { $x:ident <- $y:expr $rest ... } } => {
    $y(function($x) {
      return invert { $rest ... }
    })
  }
  rule { { $y:expr } } => { $y }

richdougherty

import play.api._
import play.api.mvc._

object Global extends GlobalSettings {

  case class RewrittenRequestHeader(val path: String, delegate: RequestHeader) extends RequestHeader {
    def id = delegate.id
    def tags = delegate.tags
    def uri = delegate.uri
    def method = delegate.method

richdougherty

import play.api._
import play.api.mvc._
import scala.concurrent.Future

object RewrittenRequestHeader {
  def rewrite(header: RequestHeader): RequestHeader = {
    if (header.path.startsWith("//")) {
      val newPath = header.path.substring(1)
      RewrittenRequestHeader(newPath, header)
    } else {

richdougherty

import play.api._
import play.api.mvc._
 
object Global extends GlobalSettings {
 
  case class RewrittenRequestHeader(val path: String, delegate: RequestHeader) extends RequestHeader {
    def id = delegate.id
    def tags = delegate.tags
    def uri = delegate.uri
    def method = delegate.method