ZIO learning - interrupting a sub command & its process / published by https://github.com/dacr/code-examples-manager #94b93765-4924-4ce4-b8fb-81fd80b27e29/a66d7074e8a0a9b24fab216171f183f3363efd14

zio-learning-process-2-kill.sc

// summary : ZIO learning - interrupting a sub command & its process
// keywords : scala, zio, learning, process, commands, pure-functional, @testable
// publish : gist
// authors : David Crosson
// license : Apache License Version 2.0 (https://www.apache.org/licenses/LICENSE-2.0.txt)
// id : 94b93765-4924-4ce4-b8fb-81fd80b27e29
// created-on : 2022-01-15T11:35:16+01:00
// managed-by : https://github.com/dacr/code-examples-manager
// run-with : scala-cli $file

// ---------------------
//> using scala "3.4.2"
//> using dep "dev.zio::zio:2.0.13"
//> using dep "dev.zio::zio-process:0.7.2"
// ---------------------

import zio.*
import zio.process.*

object Encapsulated extends ZIOAppDefault:
  def run =
    for
      process    <- Command("vmstat", "1").redirectErrorStream(true).run
      linesFiber <- process.stdout.lines.fork
      _          <- Clock.sleep(5.seconds)
      _          <- process.killTree
      lines      <- linesFiber.join
      _          <- Console.printLine(s"Gotten lines = ${lines.mkString("\n")}")
    yield ()

Encapsulated.main(Array.empty)