Navigation Menu

Skip to content

Instantly share code, notes, and snippets.

@dacr
Last active May 6, 2023 15:40
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/c7185f113e748aa1ec25397ead0172cc to your computer and use it in GitHub Desktop.
Save dacr/c7185f113e748aa1ec25397ead0172cc to your computer and use it in GitHub Desktop.
ZIO live session - Dealing with long running operation / published by https://github.com/dacr/code-examples-manager #0079acb0-25b3-4e0b-860e-b5d7d75d1699/c5231ddcd3cf73e9a4435f54d932b89bc8a34637
// summary : ZIO live session - Dealing with long running operation
// keywords : scala, zio, live, demo, 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 : 0079acb0-25b3-4e0b-860e-b5d7d75d1699
// created-on : 2021-09-26T16:27:18+02:00
// managed-by : https://github.com/dacr/code-examples-manager
// run-with : scala-cli $file
// ---------------------
//> using scala "3.2.2"
//> using dep "dev.zio::zio:2.0.13"
//> using dep "fr.janalyse::zio-worksheet:2.0.13.0"
// ---------------------
import zio.*, zio.worksheet.*, scala.io.Source
Source.fromURL("https://www.mapland.fr/ip").mkString
val logic = ZIO.attemptBlocking(Source.fromURL("https://www.mapland.fr/ip").mkString)
logic
.tap(result => Console.printLine(result))
.unsafeRun
logic
.timeout(Duration.fromMillis(100))
.tap(resultOption => Console.printLine(resultOption.getOrElse("Nothing")))
.unsafeRun
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment