This is a collection of the things I believe about software development. I have worked for years building backend and data processing systems, so read the below within that context.
Agree? Disagree? Feel free to let me know at @JanStette. See also my blog at www.janvsmachine.net.
Keep it simple, stupid. You ain't gonna need it.
| final case class ZIO[-R, +E, +A](run: R => Either[E, A]) { | |
| final def map[B](f: A => B): ZIO[R, E, B] = | |
| ZIO(r => run(r).map(f)) | |
| final def flatMap[R1 <: R, E1 >: E, B](f: A => ZIO[R1, E1, B]): ZIO[R1, E1, B] = | |
| ZIO(r => run(r).flatMap(a => f(a).run(r))) | |
| final def provide(r: R): ZIO[Any, E, A] = | |
| ZIO(_ => run(r)) |
| import monix.eval.Task | |
| import java.util.concurrent.TimeUnit | |
| import scala.concurrent.duration._ | |
| /** Request limiter for APIs that have quotas per second, minute, hour, etc. | |
| * | |
| * {{{ | |
| * // Rate-limits to 100 requests per second | |
| * val limiter = TaskLimiter(TimeUnit.SECONDS, limit = 100) | |
| * |
FWIW: I (@rondy) am not the creator of the content shared here, which is an excerpt from Edmond Lau's book. I simply copied and pasted it from another location and saved it as a personal note, before it gained popularity on news.ycombinator.com. Unfortunately, I cannot recall the exact origin of the original source, nor was I able to find the author's name, so I am can't provide the appropriate credits.
| import java.io.{File, FileInputStream, FileOutputStream} | |
| import monix.eval.Task | |
| import monix.execution.Ack | |
| import monix.execution.Ack.{Continue, Stop} | |
| import monix.reactive.{Consumer, Observable, Observer} | |
| import scala.util.control.NonFatal | |
| def copyFile(input: File, destination: File, chunkSize: Int): Task[Unit] = | |
| Task.defer { | |
| val in = new FileInputStream(input) |