Skip to content

Instantly share code, notes, and snippets.

View ktoso's full-sized avatar
🗻
Life is Study!

Konrad `ktoso` Malawski ktoso

🗻
Life is Study!
1.6k followers · 175 following
View GitHub Profile
@ktoso
ktoso / processbuilder_creation.scala
Last active August 29, 2015 14:20
ProcessBuilder showdown!
/*
* Copyright (C) 2015 Typesafe Inc. <http://www.typesafe.com>
*/
package akka.benchmarks
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
@ktoso
ktoso / spec.scala
Created March 31, 2015 15:30
tck test for 1 element publisher
/**
* Copyright (C) 2014 Typesafe Inc. <http://www.typesafe.com>
*/
package akka.stream.tck
import akka.stream.impl.MaterializedValuePublisher
import org.reactivestreams.Publisher
class MaterializedValuePublisherTest extends AkkaPublisherVerification[Any] {
@ktoso
ktoso / structural_types_slow.scala
Last active August 29, 2015 14:16
structural types are slow :-)
package com.typesafe.benchmarks
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
@State(Scope.Benchmark)
@BenchmarkMode(Array(Mode.AverageTime))
@OutputTimeUnit(TimeUnit.NANOSECONDS)
class ReflectBenchmark {
@ktoso
ktoso / to-stack-or-not-to-stack.scala
Created March 3, 2015 23:03
package whoop.whoop
import java.util.concurrent.TimeUnit
import org.openjdk.jmh.annotations._
import scala.util.control.NoStackTrace
@State(Scope.Benchmark)
@BenchmarkMode(Array(Mode.AverageTime))
@ktoso
ktoso / content
Created February 25, 2015 09:38
[error] /Users/ktoso/code/akka/akka-samples/akka-docs-java-lambda/src/test/java/docs/stream/FlowGraphDocTest.java:103: error: no suitable method found for closed(Sink<Integer,Future<Integer>>,Sink<Integer,Future<Integer>>,(b,top,bot[...]m); })
[error] FlowGraph.factory().closed(topHeadSink, bottomHeadSink, (b, top, bottom) -> {
[error] ^
[error] method GraphCreate.<S1#1,M#1>closed(Graph<S1#1,M#1>,Procedure2<Builder,S1#1>) is not applicable
[error] (cannot infer type-variable(s) S1#1,M#1
[error] (actual and formal argument lists differ in length))
[error] method GraphCreate.<S1#2,S2#1,M1#1,M2#1,M#2>closed(Graph<S1#2,M1#1>,Graph<S2#1,M2#1>,Function2<M1#1,M2#1,M#2>,Procedure3<Builder,S1#2,S2#1>) is not applicable
[error] (cannot infer type-variable(s) S1#2,S2#1,M1#1,M2#1,M#2
[error] (actual and formal argument lists differ in length))
[error] method GraphCreate.<S1#3,S2#2,S3#1,M1#2,M2#2,M3#1,M#3>closed(Graph<S1#3,M1#2>,Graph<S2#2,M2#2>,Graph<
@ktoso
ktoso / content
Created February 23, 2015 22:10
bufSize
@ktoso
ktoso / content
Created February 13, 2015 11:45
object Fair {
final case class Ports[T]() extends FlexiPorts[T](name = "Fair") {
val input1 = createInputPort[T]()
val input2 = createInputPort[T]()
}
final case class Logic[T]() extends FlexiMerge[T, Ports[T]](Ports()) {
val readAny = State[T](ReadAny(ports.input1, ports.input2)) { (ctx, input, element) ⇒
@ktoso
ktoso / out.txt
Last active April 19, 2016 10:09
Akka Streams: opening a new TCP connection if the server closes it
-----
asdf server (does nothing, then times out):
TIMEOUT: Exception `WEBrick::HTTPStatus::EOFError' at /System/Library/Frameworks/Ruby.framework/Versions/2.0/usr/lib/ruby/2.0.0/webrick/httpserver.rb:80 - WEBrick::HTTPStatus::EOFError
-----
[info] Running akka.stream.will.WillApp
RECONNECT: start a new connection!
BECAUSE TCP CLOSED: [INFO] [02/11/2015 01:29:36.962] [default-akka.actor.default-dispatcher-3] [akka://default/system/IO-TCP-STREAM/client-1-%2F127.0.0.1%3A9292] Message [akka.io.Tcp$Closed$] from Actor[akka://default/system/IO-TCP/selectors/$a/0#234029134] to Actor[akka://default/system/IO-TCP-STREAM/client-1-%2F127.0.0.1%3A9292#49317068] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
[INFO] [02/11/2015 01:29:36.962] [default-akka.actor.default-dispatcher-3] [akka://default/system/IO-TCP/selectors/$a/0] Message [akka.dispatch.sysmsg.DeathWatchNotification
@ktoso
ktoso / content
Created February 10, 2015 18:45
[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)
@ktoso
ktoso / content
Created February 8, 2015 16:50
// 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