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 February 3, 2026 19:52
David's programming examples knowledge base / published by https://github.com/dacr/code-examples-manager #fecafeca-feca-feca-feca-fecafecafeca/8190d90bea59408fd7da77ad14c120cd28c92f71

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.