ktoso

case class ManyCommand(nums: List[Int])

case class State(count: Int) {
  def updated(more: Int) = State(count + more)
}

sealed trait Event
case class AddOneEvent(num: Int) extends Event

class MultiCounter extends EventsourcedProcessor {

ktoso

Journal plugins

• BDB plugin
• Cassandra plugin
• HBase plugin
• MapDB plugin
• MongoDB plugin (by ddevore)
• MongoDB plugin (by scullxbones)

ktoso

for {
  item <- items
  transformed = transform(item)
} yield transformed

// let's say you need a println

def print(a: Any) = { println(a); a }
for {
  item <- items

ktoso

/**
 * Use for testing.
 * 
 * Forwards all messages received to the system's EventStream.
 * Use this to deterministically `awaitForLeaderElection` etc.
 */
trait EventStreamAllMessages {
  this: Actor =>

  override def aroundReceive(receive: Actor.Receive, msg: Any) = {

ktoso

// Use Gists to store code you would like to remember later on
console.log(window); // log the "window" object to the console

ktoso

def writeAsync(persistentBatch: immutable.Seq[PersistentRepr]): Future[Unit]
 
def deleteAsync(processorId: String, fromSequenceNr: Long, toSequenceNr: Long, permanent: Boolean): Future[Unit]
 
def confirmAsync(processorId: String, sequenceNr: Long, channelId: String): Future[Unit]

// and "replay":

def replayAsync(processorId: String, fromSequenceNr: Long, toSequenceNr: Long)
              (replayCallback: (PersistentRepr) => Unit): Future[Long]

ktoso

import pl.project13.hadoop.scalding.NoJarTool

import com.twitter.scalding
import org.apache.hadoop.util.ToolRunner
import org.apache.hadoop.conf.Configuration


val conf = new Configuration
val masterIp = "10.0.0.1"

ktoso

scala> :javap MongoDB
public class MongoDB$ extends java.lang.Object {
    public static final MongoDB$ MODULE$; // actual instance of our `object`
    public static {};                     
    public MongoDB$();
    // ...
}

ktoso

package tv.yap.common.zip

import collection.mutable
import java.util.zip.{ZipEntry, ZipFile}
import java.io._
import tv.yap.logging.Logging
import collection.JavaConversions._
import tv.yap.common.util.{TimedVerb, StreamOperations}
import org.apache.commons.io.{IOUtils, FilenameUtils}
import org.apache.commons.compress.compressors.bzip2.BZip2CompressorInputStream

ktoso

// or even more plain:
testCases.foreach((case) -> {
  // given
  Object given = case.given;
  Object expected = case.expected;
  
  it.should("return [%s] when applied to [%s]", given, expected, system -> {
    // when
    Object got = system.doThing(given);