Skip to content

Instantly share code, notes, and snippets.

@dacr
Last active May 25, 2024 10:19
Show Gist options
  • Save dacr/0b10a0d6be3489f3580f7272bf869c9c to your computer and use it in GitHub Desktop.
Save dacr/0b10a0d6be3489f3580f7272bf869c9c to your computer and use it in GitHub Desktop.
ZIO learning - playing with nio - list files / published by https://github.com/dacr/code-examples-manager #f9294fae-cc2e-4c4d-a8fb-6623e8857abb/b7988aef5d4854e854d30dc9c45586cc4504b186
// summary : ZIO learning - playing with nio - list files
// keywords : scala, zio, learning, nio, file, stream, sink, pure-functional, @testable
// publish : gist
// authors : David Crosson
// license : Apache NON-AI License Version 2.0 (https://raw.githubusercontent.com/non-ai-licenses/non-ai-licenses/main/NON-AI-APACHE2)
// id : f9294fae-cc2e-4c4d-a8fb-6623e8857abb
// created-on : 2021-04-06T17:34:35Z
// managed-by : https://github.com/dacr/code-examples-manager
// run-with : scala-cli $file
// ---------------------
//> using scala "3.4.2"
//> using dep "dev.zio::zio-nio:2.0.1"
// ---------------------
import zio.*
import zio.stream.*
import zio.nio.file.*
object App extends ZIOAppDefault {
val filesStream = for {
file <- Files.list(Path("/tmp"))
} yield file
// val logic = filesStream.foreach(f => putStrLn(f.toString()))
val logic = for {
result <- filesStream.run(ZSink.collectAll)
_ <- Console.printLine(result.mkString("\n"))
} yield ()
override def run = logic
}
// -------------------------------------------------------------
App.main(Array.empty)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment