Akka references serialization with Protobufs - 1

AkkaRefsSerializationOps1.scala

// allow serialization of akka goodies, e.g. streamrefs that we use
object AkkaRefsSerializationOps {

  def toProtoPayload(akkaRefToSerialize: AnyRef)(implicit system: ActorSystem): SerializedAkkaPayload = {
    val ext        = SerializationExtension(system)
    val serializer = ext.findSerializerFor(akkaRefToSerialize)
    val manifest   = Serializers.manifestFor(serializer, akkaRefToSerialize)
    val sinkSerialized = ByteString.copyFrom(serializer.toBinary(akkaRefToSerialize))
    SerializedAkkaPayload(sinkSerialized, manifest, serializer.identifier)
  }

  def fromProtoPayload[T](proto: SerializedAkkaPayload)(implicit system: ActorSystem): T = {
    val sinkRef = SerializationExtension(system).deserialize(proto.payload.toByteArray, proto.serializerId.toInt, proto.manifest)
    sinkRef.get.asInstanceOf[T]
  }
}