module
Turnir::Client
Extended Modules
Defined in:
turnir/client/client.crturnir/client/vk_client.cr
Constant Summary
-
CLIENTS =
{ClientType::VKVIDEO => Client.new(ClientType::VKVIDEO, Turnir::Client::VkWebsocket), ClientType::TWITCH => Client.new(ClientType::TWITCH, Turnir::Client::TwitchWebsocket), ClientType::NUUM => Client.new(ClientType::NUUM, Turnir::Client::NuumPolling), ClientType::GOODGAME => Client.new(ClientType::GOODGAME, Turnir::Client::GoodgameWebsocket)}
-
STREAMS_STATUS_MAP =
Hash(String, Stream).new
-
STREAMS_STATUS_MAP_MUTEX =
Mutex.new
Instance Method Summary
- #clear_messages(client_type : ClientType)
- #clear_streams_for_client(client_type : ClientType)
- #client_auto_stopper
- #disconnect_streams_for_client(client_type : ClientType)
- #ensure_client_running(client_type : ClientType)
- #get_connections_statuses
- #get_messages(client_type : ClientType, channel : String, since : Int64, text_filter : String)
- #get_stream_status(stream_name : String) : ConnectionStatus
- #log(msg)
- #on_subscribe(client : ClientType, channel : String)
- #stream_activity_checker
- #subscribe_to_channel(client_type : ClientType, channel_name : String)
- #subscribe_to_channel_if_not_subscribed(client_type : ClientType, channel_name : String) : ConnectionStatus
Instance Method Detail
def get_messages(client_type : ClientType, channel : String, since : Int64, text_filter : String)
#
def subscribe_to_channel_if_not_subscribed(client_type : ClientType, channel_name : String) : ConnectionStatus
#