Roland Kuhn rkuhn

Keybase proof

I hereby claim:

I am rkuhn on github.
I am rkuhn (https://keybase.io/rkuhn) on keybase.
I have a public key whose fingerprint is A5B2 DDE7 843E 7CA3 E8CA ABD0 2383 163B C408 44FD

To claim this, I am signing this object:

The akka/akka Gitter Channel

This channel is available for all Akka enthusiasts—newbies as well as gurus—for the exchange of knowledge and the coordination of efforts around Akka; it is a community effort and resource and not backed by Typesafe. For more structured discussions please refer to the akka-user mailing list.

Instead of a long Code of Conduct we rely upon common sense: be kind and respectful to those who are already here and to those who come after you, harassment of any kind will not be tolerated; in case of trouble contact akka.official.

Please also note that this is not an official Akka support channel, for commercial support please contact Typesafe or visit Typesafe.com.

Some limits of equational reasoning

This is a follow-up on a discussion on gitter I had with Rob Norris. Gitter is great, but it is easier to make a coherent argument in a gist.

The monad laws allow us to assert that in the following the two results will describe computations that eventually yield the same value:

val fut1 = Future(<comp1>)
val fut2 = Future()

	import java.io.DataInputStream
	import scala.annotation.tailrec

	object LineNumbers {
	sealed trait Result
	case object NoSourceInfo extends Result
	case class SourceFile(filename: String) extends Result {
	override def toString = filename
	}
	case class SourceFileLines(filename: String, from: Int, to: Int) extends Result {

	java.lang.RuntimeException: buh
	at docs.actor.ActorDocTest.lambda$t$207(ActorDocTest.java:86)
	at docs.actor.ActorDocTest$$Lambda$21/1048855692.doit(Unknown Source)
	at docs.actor.ActorDocTest.m(ActorDocTest.java:80)
	at docs.actor.ActorDocTest.t(ActorDocTest.java:85)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:483)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)

	class MergeSorted[T: Ordering] extends GraphStage[FanInShape2[T, T, T]] {
	private val left = Inlet[T]("left")
	private val right = Inlet[T]("right")
	private val out = Outlet[T]("out")

	override val shape = new FanInShape2(left, right, out)

	override def createLogic(attr: Attributes) = new GraphStageLogic(shape) {
	import Ordering.Implicits._
	setHandler(left, ignoreTerminateInput)

	import scala.annotation.unchecked.uncheckedVariance

	object Trial2712 {
	trait NotUsed
	import language.higherKinds

	/*
	* The following are simplified versions of FlowOps / FlowOpsMat and their
	* concrete subtypes.
	*/

	package akka.typed

	import scala.concurrent.duration._
	import org.coroutines._

	object Coroutines {
	/**
	* This will be a collection of all the management commands that are sent
	* to a Session-hosting Actor via its main channel (i.e. the ActorRef that
	* is returned directly for it).

	package com.rolandkuhn.rs;

	import java.net.InetSocketAddress;
	import java.net.SocketAddress;
	import java.util.concurrent.Executors;
	import java.util.concurrent.TimeUnit;

	import io.reactivesocket.ReactiveSocket;
	import io.reactivesocket.client.KeepAliveProvider;
	import io.reactivesocket.client.ReactiveSocketClient;