ktoso

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

project akka-sample-persistence-java
test

project akka-sample-persistence-scala

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

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

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

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

import org.reactivestreams.{ Publisher, Subscriber }

class Experiments {

  trait Graph {

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.javadsl.japi;

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

import java.util.concurrent.Future;

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

trait DrainWithKey[-In, +MaterializedType] extends Drain[In, MaterializedType] {

//  type MaterializedType

  /**
   * Attach this drain to the given [[org.reactivestreams.Publisher]]. Using the given
   * [[FlowMaterializer]] is completely optional, especially if this drain belongs to
   * a different Reactive Streams implementation. It is the responsibility of the
   * caller to provide a suitable FlowMaterializer that can be used for running
   * Flows if necessary.

ktoso

FoldDrain<String, String> fold = new FoldDrain<String, String>();
    Future<String> got = materialized.getDrainFor(fold);
  }
}

class FoldDrain<In, Res> extends DrainWithTheKey<In, Future<Res>> { }

class DrainWithTheKey<In, Res> {
  public Res something() { return null; }
}