raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Fixing dead code in MessageContainerSerializer.scala

Browse source
This commit is contained in:
Viktor Klang 2013-08-06 02:14:31 +02:00
parent 6783bb2729
commit 3a6497efb4
1 changed files with 3 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-remote/src/main/scala/akka/remote/serialization/MessageContainerSerializer.scala
View file

@ -23,17 +23,14 @@ class MessageContainerSerializer(val system: ExtendedActorSystem) extends Serial
def includeManifest: Boolean = false
def toBinary(obj: AnyRef): Array[Byte] = obj match {
case path: SelectionPath ⇒
val builder = ContainerFormats.SelectionEnvelope.newBuilder()
serializeSelectionPath(path, builder)
builder.build().toByteArray
case _ ⇒ throw new IllegalArgumentException(s"Cannot serialize object of type [${obj.getClass.getName}]")
case path: SelectionPath ⇒ serializeSelectionPath(path, ContainerFormats.SelectionEnvelope.newBuilder()).build().toByteArray
case _ ⇒ throw new IllegalArgumentException(s"Cannot serialize object of type [${obj.getClass.getName}]")
}
import ContainerFormats.PatternType._
@tailrec
private def serializeSelectionPath(path: Any, builder: SelectionEnvelope.Builder): Unit = path match {
private def serializeSelectionPath(path: Any, builder: SelectionEnvelope.Builder): SelectionEnvelope.Builder = path match {
case SelectChildName(name, next) ⇒
serializeSelectionPath(next, builder.addPattern(buildPattern(Some(name), CHILD_NAME)))
case SelectChildPattern(pattern, next) ⇒