WriteChannelWithExpiration
class WriteChannelWithExpiration[F[_], A](internal: WriteChannel[F, A], ttl: FiniteDuration, throwTimeouts: Boolean, gopherApi: Gopher[F]) extends WriteChannel[F, A]
Channel, where messages can be exprited.
Type members
Inherited types
Value members
Concrete methods
override
def withWriteExpiration(ttl: FiniteDuration, throwTimeouts: Boolean)(using gopherApi: Gopher[F]): WriteChannelWithExpiration[F, A]
- Definition Classes
- Source
- WriteChannelWithExpiration.scala