ktoso

/**
 * Copyright (C) 2014 Typesafe Inc. <http://www.typesafe.com>
 */
package akka.stream.javadsl.japi;

import org.reactivestreams.Subscriber;

import java.util.concurrent.Future;

public class JavaPain {

ktoso

/**
 * Copyright (C) 2014 Typesafe Inc. <http://www.typesafe.com>
 */
package akka.stream.javadsl.japi;

import akka.stream.javadsl.MaterializedDrain;
import org.reactivestreams.Subscriber;

import java.util.concurrent.Future;

ktoso

# Reactive Streams TCK #

The purpose of the *Reactive Streams Technology Compatibility Kit* (from here on refered to as: *the TCK*) is to guide
and help Reactive Streams library implementors to validate their implementations against the rules defined in [the Specification](https://github.com/reactive-streams/reactive-streams).

The TCK is implemented using plain Java and **TestNG** tests, and should be possible to use from other languages and testing libraries (such as Scala, Groovy, JRuby or others).

## Types of tests included in the TCK

The TCK aims to cover all rules defined in the Specification, however for some rules outlined in the Specification it is

ktoso

/**
* Copyright (C) 2014 Typesafe Inc. <http://www.typesafe.com>
*/
package akka.stream

import org.reactivestreams.{ Publisher, Subscriber }

class Experiments {

  trait Graph {

ktoso

Keybase proof

I hereby claim:

• I am ktoso on github.
• I am ktoso (https://keybase.io/ktoso) on keybase.
• I have a public key whose fingerprint is 858C 241C 59E3 A807 16B9 E4C4 9EDE 9520 2988 51A7

To claim this, I am signing this object:

ktoso

package sample.cluster.simple

import akka.actor.Actor.Receive
import akka.routing.{Broadcast, RoundRobinPool}
import com.typesafe.config.ConfigFactory
import akka.remote.RemoteScope
import akka.actor._

import scala.util.Random

ktoso

/**
 * Copyright (C) 2014 Typesafe Inc. <http://www.typesafe.com>
 */
package akka.event

import java.util.concurrent.TimeUnit

import akka.actor._
import akka.testkit._
import akka.event.Logging.LogLevel

ktoso

#!/bin/sh
sbt shell <<HERE
project akka-docs
test
sphinx:generateHtml

project akka-sample-persistence-java
test

project akka-sample-persistence-scala

ktoso

2014-06-22 12:45:37
Full thread dump Java HotSpot(TM) 64-Bit Server VM (25.0-b70 mixed mode):

"Attach Listener" #87 daemon prio=9 os_prio=31 tid=0x00007fe6bc084000 nid=0x651f waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"pool-9-thread-7" #86 prio=5 os_prio=31 tid=0x00007fe6bf504800 nid=0x9d03 waiting on condition [0x0000000126b70000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000780f9f760> (a java.util.concurrent.SynchronousQueue$TransferStack)

ktoso

Monday June 16th

Scala: The Simple Parts

• Martin Odersky - @odersky

Tuesday June 17th