Call brotli from scala - pass it a string to compress and receive a byte array

brotli.scala

package com.github.sguzman.scraper.stream.lord

import java.io.{DataInputStream, DataOutputStream}

import scala.sys.process._

object Brotli extends App {
  def compress(s: String): Array[Byte] = {
    locally {
      var output: Array[Byte] = null
      val cmd = "brotli"
      val proc = cmd.run(new ProcessIO(
        in => {
          val writer = new java.io.PrintWriter(in)
          writer.write(s)
          writer.close()
        },
        out => {
          val src = new DataInputStream(out)
          output = src.readAllBytes
          src.close()
        },
        _.close()
      ))

      val code = proc.exitValue()
      println(s"Subprocess exited with code $code.")

      output
    }
  }

  def decompress(s: Array[Byte]): String = {
    locally {
      var output: String = ""
      val calcCommand = "brotli -d"
      val calcProc = calcCommand.run(new ProcessIO(
        in => {
          val writer = new DataOutputStream(in)
          writer.write(s)
          writer.close()
        },
        out => {
          val src = scala.io.Source.fromInputStream(out)
          output = src.getLines.mkString
          src.close()
        },
        _.close()
      ))

      val code = calcProc.exitValue()
      println(s"Subprocess exited with code $code.")

      output
    }
  }

}