Skip to content

Instantly share code, notes, and snippets.

@dacr
Last active April 2, 2023 18:56
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • 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/dbbf3441bd592f88ce8b5901b3a47e5d6bb26dd6
// 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.2.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