sender-sdk/tv.vizbee.model.controllers.services.common.wsprocessor/WSProcessor

WSProcessor

open class WSProcessor

Constructors

constructor(uri: URI, fallbackUri: URI)

Types

enum Event

enum State

Functions

open fun addCommand(command: WSCommand)

open fun flush()

getAsyncWebSocket

@VisibleForTesting

open fun getAsyncWebSocket(): AsyncWebSocket

getCommandQueue

@VisibleForTesting

open fun getCommandQueue(): List<WSCommand>

@VisibleForTesting

open fun getState(): WSProcessor.State

open fun isConnected(): Boolean

onProcessingFailure

@VisibleForTesting

open fun onProcessingFailure(error: VizbeeError)

@VisibleForTesting

open fun process(e: WSProcessor.Event)

@VisibleForTesting

open fun processCommand()

processResponse

@VisibleForTesting

open fun processResponse(response: String)

retryWSConnectWithFallbackUri

@VisibleForTesting

open fun retryWSConnectWithFallbackUri(): Boolean

setAsyncWebSocket

@VisibleForTesting

open fun setAsyncWebSocket(mAsyncWebSocket: AsyncWebSocket)

setCurrentCommand

@VisibleForTesting

open fun setCurrentCommand(command: WSCommand)

open fun setListener(@NonNull wsMetricsListener: WebSocketMetricsListener)

@VisibleForTesting

open fun setState(mState: WSProcessor.State)

setTrustManagers

open fun setTrustManagers(trustManagers: Array<TrustManager>)

Properties

@get:VisibleForTesting

open val currentUri: URI

@get:VisibleForTesting

open val fallbackUri: URI

val LOG_TAG: String

@get:VisibleForTesting

open val preferredUri: URI