Skip to content

Instantly share code, notes, and snippets.

View himanshu4141's full-sized avatar
:bowtie:

Himanshu yadav himanshu4141

:bowtie:
View GitHub Profile
@dacr
dacr / index.md
Last active October 16, 2024 19:54
David's programming examples knowledge base / published by https://github.com/dacr/code-examples-manager #fecafeca-feca-feca-feca-fecafecafeca/16e5e3ae008b840d9fabb81cecb8edcf384a94a1

David's programming examples knowledge base

akka-pekko

import java.time.Instant
import scala.concurrent.duration._
import fs2._
object Retries {
/**
* Returns a stream that evaluates the specified task once and then for each unit that appears in the `changes` stream. If any task evaluation
* fails with an exception, the task is retried according to the specified `retryDelay` schedule until it succeeds or a value from the `changes`
* stream appears.