utilities for serializing and deserializing functions

LambdaUtil.scala

object LambdaUtil:
  import java.lang.invoke.{MethodHandleInfo, SerializedLambda}

  def serializeLambda(closure: AnyRef): Array[Byte] =
    val writeReplace = closure.getClass.getDeclaredMethod("writeReplace")
    writeReplace.setAccessible(true)
    val serializable = writeReplace.invoke(closure).asInstanceOf[SerializedLambda]
    val bytes = new java.io.ByteArrayOutputStream
    val os = new java.io.ObjectOutputStream(bytes)
    try
      os.writeObject(serializable)
    finally
      os.close()
    bytes.toByteArray


  def deserializeLambda[A](loader: ClassLoader, bytes: Array[Byte]): A =
    val byteStream = new java.io.ByteArrayInputStream(bytes)
    val os = new java.io.ObjectInputStream(byteStream):
      override def resolveClass(desc: java.io.ObjectStreamClass): Class[_] =
        Class.forName(desc.getName, false, loader)
    val lambda = os.readObject()
    lambda.asInstanceOf[A]