Lagom Framework Opinionated Microservices Framework Play Framework High velocity
web framework Scala The JVM language
of pragmatism
Akka Actor-based,
cloud native toolkit
From the creators of Akka, get technology enhancements, monitoring, and expert support with Lightbend Platform. See Akka In Lightbend Platform
The Lightbend Family

Akka Documentation

Version 2.6.1

keepAlive

Injects additional (configured) elements if upstream does not emit for a configured amount of time.

Time aware operators

Signature

def keepAlive[U >: Out](maxIdle: FiniteDuration, injectedElem: () => U): Repr[U]

Description

Injects additional (configured) elements if upstream does not emit for a configured amount of time.

Reactive Streams semantics

emits when upstream emits an element or if the upstream was idle for the configured period

backpressures when downstream backpressures

completes when upstream completes

cancels when downstream cancels

backpressureTimeout
throttle
Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.