o

ackcord.util

GuildStreams

object GuildStreams

Source
GuildStreams.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. GuildStreams
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def apiMessageGroupByGuildId[Msg <: APIMessage]: SubFlow[Msg, NotUsed, [+O]Flow[Msg, O, NotUsed], Sink[Msg, NotUsed]]

    Creates a subflow grouped by what GuildId a message belongs to.

  2. def createGatewayGuildInfoExtractor(log: Logger): (GatewayEvent[_]) => Option[GuildId]

    A function which tries to find out which guild a given GatewayEvent event belongs to.

    A function which tries to find out which guild a given GatewayEvent event belongs to.

    Handles

    The function returned by this contains multiple state, and is not safe to share.

  3. def gatewayEventGroupByGuildId[Msg <: GatewayEvent[_]](log: Logger): SubFlow[Msg, NotUsed, [+O]Flow[Msg, O, NotUsed], Sink[Msg, NotUsed]]

    Creates a subflow grouped by what GuildId an event belongs to.

  4. def guildFilterApiMessage[Msg <: APIMessage](guildId: GuildId): Flow[Msg, Msg, NotUsed]

    Serves the opposite function of GuildRouter.

    Serves the opposite function of GuildRouter. The job of the guild filter is to only allow messages that belong to a specific guild.

    Handles

    Global events like APIMessage.Ready, APIMessage.Resumed and APIMessage.UserUpdate are sent no matter what.

    guildId

    The only guildID to allow through.

  5. def guildFilterGatewayEvent[Msg <: GatewayEvent[_]](guildId: GuildId, log: Logger): Flow[Msg, Msg, NotUsed]

    GuildFilter serves the opposite function of GuildRouter.

    GuildFilter serves the opposite function of GuildRouter. The job of the guild filter is to only send messages to one actor that matches a specific guild.

    Handles

    Global events like ackcord.gateway.GatewayEvent.Ready, ackcord.gateway.GatewayEvent.Resumed and ackcord.gateway.GatewayEvent.UserUpdate are sent no matter what.

    guildId

    The only guildID to allow through.

  6. def withGuildInfoApiMessage[Msg <: APIMessage]: Flow[Msg, (Msg, Option[GuildId]), NotUsed]

    A flow which tries to find out which guild a given APIMessage event belongs to.

    A flow which tries to find out which guild a given APIMessage event belongs to.

    Handles

  7. def withGuildInfoGatewayEvent[Msg <: GatewayEvent[_]](log: Logger): Flow[Msg, (Msg, Option[GuildId]), NotUsed]

    A flow which tries to find out which guild a given GatewayEvent event belongs to.

    A flow which tries to find out which guild a given GatewayEvent event belongs to.

    Handles