Packages

package internals

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. case class PubSubState[F[_], K, V](channelSubs: AtomicCell[F, Map[RedisChannel[K], Redis4CatsSubscription[F, V]]], patternSubs: AtomicCell[F, Map[RedisPattern[K], Redis4CatsSubscription[F, RedisPatternEvent[K, V]]]]) extends Product with Serializable

    We use AtomicCell instead of Ref because we need locking while side-effecting.

Value Members

  1. object LivePubSubStats
  2. object PubSubInternals
  3. object PubSubState extends Serializable
  4. object Subscriber

Ungrouped