Package tv.phantombot.twitch.irc

Class TwitchSession

java.lang.Object
java.util.concurrent.SubmissionPublisher<Message>
tv.phantombot.twitch.irc.chat.utils.MessageQueue
tv.phantombot.twitch.irc.TwitchSession
All Implemented Interfaces:
AutoCloseable, Flow.Processor<Message,Message>, Flow.Publisher<Message>, Flow.Subscriber<Message>
public class TwitchSession extends MessageQueue

  • Constructor Details

    • TwitchSession

      public TwitchSession(String channelName, String botName)
      Class constructor.
      Parameters:
      channelName -
      botName -

  • Method Details

    • doSubscribe

      public void doSubscribe()

    • getChannelName

      public String getChannelName()
      Method that returns the channel name
      Returns:
      channelName

    • joinSuccess

      public void joinSuccess()

    • getBotName

      public String getBotName()
      Method that returns the bot name.
      Returns:
      botName

    • getWrites

      public int getWrites()

    • send

      public void send(String message)
      Method that sends channel message.
      Parameters:
      message -

    • getModerationStatus

      public void getModerationStatus()
      Method that will do the moderation check of the bot.

    • reconnect

      public void reconnect()
      Method that handles reconnecting with Twitch.

    • onNext

      public void onNext(Message message)

    • onComplete

      public void onComplete()

    • quitIRC

      public void quitIRC()

    • close

      public void close()
      Method that stops everything for TwitchWSIRC, there's no going back after this.
      Specified by:
      close in interface AutoCloseable
      Overrides:
      close in class SubmissionPublisher<Message>