Skip to content

Instantly share code, notes, and snippets.

View himanshu4141's full-sized avatar
:bowtie:

Himanshu yadav himanshu4141

:bowtie:
  • Nitro
  • Dublin
View GitHub Profile
@dacr
dacr / index.md
Last active November 26, 2025 19:09
David's programming examples knowledge base / published by https://github.com/dacr/code-examples-manager #fecafeca-feca-feca-feca-fecafecafeca/6e82bf2949cc61c919535ce35a58ebc93721c33

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.