ktoso

[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)

ktoso

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'

ktoso

>
>
>
> 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

/**
 * 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

ktoso

    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 }

ktoso

/*
 * 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

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

To claim this, I am signing this object:

ktoso

/*
 * 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}

ktoso

// manual array based “chunk” signalling, with blocking IO

[info] a.s.StreamFileBenchmark.getLines                                  1048576   avgt        20        6.324        0.940    ms/op << GOAL (buf 8k)
[info] a.s.StreamFileBenchmark.source_getLines                           1048576   avgt        20      174.420       25.517    ms/op // “people do this” workaround, horrible
[info] a.s.StreamFileBenchmark.source_blockingIo_chunk_1024_ahead_8      1048576   avgt        20        7.608        1.597    ms/op // eq buff (8k)
[info] a.s.StreamFileBenchmark.source_blockingIo_chunk_512_ahead_16      1048576   avgt        20        5.980        0.470    ms/op // eq buff (8k), readAhead is better!

[info] a.s.StreamFileBenchmark.source_blockingIo_chunk_256_ahead_4       1048576   avgt        20       13.358        2.463    ms/op // other buff sizes, less optimal
[info] a.s.StreamFileBenchmark.source_blockingIo_chunk_256_ahead_8       1048576   avgt        20       12.497        1.710    ms/op
[info] a.s.StreamFi

ktoso

[error] Test docs.stream.cookbook.RecipeMultiGroupBy.work failed: java.lang.BootstrapMethodError: call site initialization exception
[error]     at java.lang.invoke.CallSite.makeSite(CallSite.java:328)
[error]     at java.lang.invoke.MethodHandleNatives.linkCallSite(MethodHandleNatives.java:296)
[error]     at docs.stream.cookbook.RecipeMultiGroupBy$1.<init>(RecipeMultiGroupBy.java:77)
[error]     at docs.stream.cookbook.RecipeMultiGroupBy.work(RecipeMultiGroupBy.java:55)
[error]     ...
[error] Caused by: java.lang.invoke.LambdaConversionException: Type mismatch in captured lambda parameter 0: expecting class docs.stream.cookbook.RecipeMultiGroupBy$1, found class docs.stream.cookbook.RecipeTest
[error]     at java.lang.invoke.AbstractValidatingLambdaMetafactory.validateMetafactoryArgs(AbstractValidatingLambdaMetafactory.java:256)
[error]     at java.lang.invoke.LambdaMetafactory.metafactory(LambdaMetafactory.java:303)
[error]     at java.lang.invoke.CallSite.makeSite(CallSite.java:289)