| // Run this with scala <filename> | |
| /** | |
| * A Two-phase commit Monad | |
| */ | |
| trait Transaction[+T] { | |
| def map[U](fn: T => U): Transaction[U] = flatMap { t => Constant(fn(t)) } | |
| def flatMap[U](fn: T => Transaction[U]): Transaction[U] = | |
| FlatMapped(this, fn) |
| <!DOCTYPE html> | |
| <html lang="en"> | |
| <head> | |
| <title>livescript</title> | |
| </head> | |
| <body> | |
| <h1> | |
| Livescript - check the browser's console | |
| </h1> | |
| <h2> |
| //from https://github.com/ppurang/spray-example | |
| //below retreive(id) always returns Option[Order] | |
| trait CoffeePaymentService extends HttpService with LiftJsonSupport { | |
| self: PersistenceCoffee => | |
| override implicit def liftJsonFormats: Formats = Order.format | |
| val paymentRoute = | |
| pathPrefix("payment"/"order") { |
| trait Entry extends HttpService { | |
| val entry = path("") { | |
| get { | |
| complete { | |
| Link("order", "http://localhost:8080/order", "*/*,plain/text,application/json") | |
| } | |
| } | |
| } | |
| } |
| May is almost upon us and the series of great meetups needs to continue. This time around we are hosted by Nokia at their fairly new building. Being an ex-Nokian (hmmm did I get that right?), I am very curious how things are in the new building. | |
| Here are the talks for the evening: | |
| Christoph Knabe presents "Redundant History of Programming (~40 mins) | |
| Piyush Purang presents "Spray It!" (~25 mins) | |
| And we will start a discussion on the format of the meetups. |
| import java.util.{Calendar => C} | |
| import C._ | |
| def isSameDay(one: C, two: C) = one.get(ERA) == two.get(ERA) && one.get(YEAR) == two.get(YEAR) && one.get(DAY_OF_YEAR) == two.get(DAY_OF_YEAR) | |
| //is the following the same? | |
| def isSameDay2(one: C, two: C) = Math.abs(one.getTimeInMillis - two.getTimeInMillis) < 86400000 | |
| def isNotSameDayAndStillBefore(one: C, two: C) = !isSameDay(one, two) && one.before(two) |
| def breakIf[T: ClassTag](assertion: => Boolean, args: NamedParam*): Unit = | |
| if (assertion) break[T](args.toList) | |
| // start a repl, binding supplied args | |
| def break[T: ClassTag](args: List[NamedParam]): Unit = savingContextLoader { | |
| val msg = if (args.isEmpty) "" else " Binding " + args.size + " value%s.".format( | |
| if (args.size == 1) "" else "s" | |
| ) |
| import akka.actor.Actor | |
| import akka.actor.ActorSystem | |
| import akka.agent.Agent | |
| import com.typesafe.config.ConfigFactory | |
| import akka.event.Logging | |
| import akka.actor.Props | |
| import kafka.utils.Utils | |
| import java.nio.ByteBuffer |
Locate the section for your github remote in the .git/config file. It looks like this:
[remote "origin"]
fetch = +refs/heads/*:refs/remotes/origin/*
url = git@github.com:joyent/node.git
Now add the line fetch = +refs/pull/*/head:refs/remotes/origin/pr/* to this section. Obviously, change the github url to match your project's URL. It ends up looking like this:
| "copy file" in { | |
| val fileGenerator = Enumerator.repeat(new java.util.Date.getTime.toString + "\n").through(Enumeratee.take(1000)) | |
| //val fileGenerator = Enumerator.repeat(new java.util.Date.getTime.toString + "\n") &>> Enumeratee.take(1000) | |
| val f = FileChannel("/tmp/testwrite.txt").delete.writing.create | |
| val f2 = FileChannel("/tmp/testwrite2.txt").delete.writing.create | |
| fileGenerator // generates data | |
| .through(RichEnumeratee.binarize()) // binarizes data to write into File |