Konrad `ktoso` Malawski ktoso

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 008B 707E BCCA 3CCB 42B1 9BFC 6203 9E20 92E4 1668

To claim this, I am signing this object:

	/*
	* Copyright (C) 2009-2015 Typesafe Inc. <http://www.typesafe.com>
	*/

	package akka.stream

	import java.io.{BufferedWriter, File, FileInputStream, FileWriter}
	import java.nio.ByteBuffer
	import java.util.concurrent.{ArrayBlockingQueue, TimeUnit}

	/*
	* Copyright (C) 2015 Typesafe Inc. <http://www.typesafe.com>
	*/

	package akka.stream.webinar

	import java.net.InetSocketAddress

	import akka.actor.ActorSystem
	import akka.stream.FlowMaterializer


	trait Box {
	type T
	private var t: T = _
	def put(t: T) = this.t = t
	def get = t
	}

	{ // traits only
	trait IntBox extends Box { override type T = Int }

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

	import java.net.InetSocketAddress

	import akka.actor.ActorSystem
	import akka.pattern.FutureTimeoutSupport
	import akka.stream.FlowMaterializer

	>
	>
	>
	> test
	[info] * sample.cluster.stats.StatsSampleSingleMasterSpec
	[trace] Stack trace suppressed: run last test:test for the full output.

	THE ERRORS

	[error] Could not run test sample.cluster.stats.StatsSampleSingleMasterSpecMultiJvmNode1: java.lang.ExceptionInInitializerError

	ktoso @ 月 ~/code/activator-hello-akka [wip-rp-15v01p01-patriknw]
	$ activator ui
	Found previous process id: 91098
	FOUND REPO = activator-local @ file:/Users/ktoso/opt/activator-1.2.2/repository
	Play server process ID is 94878
	[info] play - Application started (Prod)
	[info] play - Listening for HTTP on /127.0.0.1:8888
	[info] a.e.s.Slf4jLogger - Slf4jLogger started
	[INFO] [12/12/2014 11:23:59.072] [default-akka.actor.default-dispatcher-2] [akka://default/user/sbt-process-1/underlying] Underlying SBT actor stopped with: java.lang.RuntimeException: Need to reboot sbt (this is expected, not a problem)
	[info] application - sbt told us the name is: 'hello-akka'

	[info] - spec103_mustSignalOnMethodsSequentially * FAILED *
	[info] java.lang.AssertionError: Async error during test execution: Expected latch to be open during onNext call, state seems to be: onSubscribe
	[info] at org.testng.Assert.fail(Assert.java:78)
	[info] at org.reactivestreams.tck.TestEnvironment.verifyNoAsyncErrors(TestEnvironment.java:160)
	[info] at org.reactivestreams.tck.PublisherVerification.activePublisherTest(PublisherVerification.java:857)
	[info] at org.reactivestreams.tck.PublisherVerification$5.apply(PublisherVerification.java:194)
	[info] at org.reactivestreams.tck.PublisherVerification$5.apply(PublisherVerification.java:191)
	[info] at org.reactivestreams.tck.PublisherVerification.stochasticTest(PublisherVerification.java:905)
	[info] at org.reactivestreams.tck.PublisherVerification.spec103_mustSignalOnMethodsSequentially(PublisherVerification.java:191)
	[info] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

	G] Running:
	Command line suite

	[info] - createPublisher1MustProduceAStreamOfExactly1Element
	[info] - createPublisher3MustProduceAStreamOfExactly3Elements
	[info] - spec101_subscriptionRequestMustResultInTheCorrectNumberOfProducedElements
	[info] - spec102_maySignalLessThanRequestedAndTerminateSubscription
	[info] - spec103_mustSignalOnMethodsSequentially !!! IGNORED !!!
	[info] - spec104_mustSignalOnErrorWhenFails
	[info] - spec105_mustSignalOnCompleteWhenFiniteStreamTerminates