case classReplayLimited[A](capacity: Int, initial: Seq[A]) extends MulticastStrategy[A] with Product with Serializable
The ReplayLimited strategy is for building multicast
observables that repeat the generated items by the source, but limited by the
maximum size of the underlying buffer.
When maximum size is reached, the underlying buffer starts dropping
older events. Note that the size of the resulting buffer is not necessarily
the given capacity, as the implementation may choose to increase it for optimisation
purposes.
The
ReplayLimitedstrategy is for building multicast observables that repeat the generated items by the source, but limited by the maximum size of the underlying buffer.When maximum size is reached, the underlying buffer starts dropping older events. Note that the size of the resulting buffer is not necessarily the given capacity, as the implementation may choose to increase it for optimisation purposes.
Corresponds to Pipe.replayLimited.