object CacheStreams
- Source
- CacheStreams.scala
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- CacheStreams
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- case class GuildCacheEvent(event: CacheEvent, respondTo: ActorRef[(CacheEvent, CacheState)]) extends Product with Serializable
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def cacheStreams(cacheProcessor: CacheProcessor, bufferSize: PubSubBufferSize = PubSubBufferSize())(implicit system: ActorSystem[Nothing]): (Sink[CacheEvent, NotUsed], Source[(CacheEvent, CacheState), NotUsed])
Creates a set of publish subscribe streams that go through the cache updated.
- def cacheStreamsCustom(updater: Flow[CacheEvent, (CacheEvent, CacheState), NotUsed], bufferSize: PubSubBufferSize = PubSubBufferSize())(implicit system: ActorSystem[Nothing]): (Sink[CacheEvent, NotUsed], Source[(CacheEvent, CacheState), NotUsed])
Creates a set of publish subscribe streams that go through a custom cache update procedure you decide.
- def cacheUpdater(cacheBuilder: CacheSnapshotBuilder): Flow[CacheEvent, (CacheEvent, CacheState), NotUsed]
A flow that keeps track of the current cache state, and updates it from cache update events.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- def createApiMessages: Flow[(CacheEvent, CacheState), APIMessage, NotUsed]
A flow that creates APIMessages from update events.
- def emptyStartingCache(cacheProcessor: CacheProcessor): CacheSnapshotBuilder
Creates a new empty cache snapshot builder.
Creates a new empty cache snapshot builder. This is not thread safe, and should not be updated from multiple threads at the same time.
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def gatewayEvents[D](bufferSize: PubSubBufferSize = PubSubBufferSize())(implicit system: ActorSystem[Nothing]): (Sink[GatewayMessage[D], NotUsed], Source[GatewayMessage[D], NotUsed])
Creates a set of publish subscribe streams for gateway events.
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def guildCacheBehavior(cacheBuilder: CacheSnapshotBuilder): Behavior[GuildCacheEvent]
- def guildCacheUpdater(guildCacheUpdateActor: ActorRef[GuildCacheEvent]): Flow[CacheEvent, (CacheEvent, CacheState), NotUsed]
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])