Skip to content

Decode inbound EXIT2 message #12

Merged
merged 1 commit into from Apr 3, 2012
View
2 src/main/scala/scalang/node/ScalaTermDecoder.scala
@@ -91,6 +91,8 @@ class ScalaTermDecoder(peer : Symbol, factory : TypeFactory) extends OneToOneDec
buffer.skipBytes(1)
val msg = readTerm(buffer)
RegSend(from, to, msg)
+ case (8, from : Pid, to : Pid, reason : Any) =>
+ Exit2Message(from, to, reason)
}
}
Something went wrong with that request. Please try again.