-
- All Implemented Interfaces:
-
com.amazon.connect.chat.sdk.network.WebSocketManager
public final class WebSocketManagerImpl implements WebSocketManager
-
-
Field Summary
Fields Modifier and Type Field Description private MutableStateFlow<Boolean>isReconnectingprivate final SharedFlow<ChatEventPayload>eventPublisherprivate final SharedFlow<Pair<TranscriptItem, Boolean>>transcriptPublisherprivate final <ERROR CLASS>requestNewWsUrlFlow
-
Constructor Summary
Constructors Constructor Description WebSocketManagerImpl(CoroutineDispatcher dispatcher, NetworkConnectionManager networkConnectionManager, ConnectionDetailsProvider connectionDetailsProvider)
-
Method Summary
Modifier and Type Method Description MutableStateFlow<Boolean>getIsReconnecting()UnitsetIsReconnecting(MutableStateFlow<Boolean> isReconnecting)SharedFlow<ChatEventPayload>getEventPublisher()SharedFlow<Pair<TranscriptItem, Boolean>>getTranscriptPublisher()<ERROR CLASS>getRequestNewWsUrlFlow()Unitconnect(String wsUrl, Boolean isReconnectFlow)Unitdisconnect(String reason)UnitsuspendWebSocketConnection()UnitresumeWebSocketConnection()TranscriptItemparseTranscriptItemFromJson(String jsonString)-
-
Constructor Detail
-
WebSocketManagerImpl
WebSocketManagerImpl(CoroutineDispatcher dispatcher, NetworkConnectionManager networkConnectionManager, ConnectionDetailsProvider connectionDetailsProvider)
-
-
Method Detail
-
getIsReconnecting
MutableStateFlow<Boolean> getIsReconnecting()
-
setIsReconnecting
Unit setIsReconnecting(MutableStateFlow<Boolean> isReconnecting)
-
getEventPublisher
SharedFlow<ChatEventPayload> getEventPublisher()
-
getTranscriptPublisher
SharedFlow<Pair<TranscriptItem, Boolean>> getTranscriptPublisher()
-
getRequestNewWsUrlFlow
<ERROR CLASS> getRequestNewWsUrlFlow()
-
disconnect
Unit disconnect(String reason)
-
suspendWebSocketConnection
Unit suspendWebSocketConnection()
-
resumeWebSocketConnection
Unit resumeWebSocketConnection()
-
parseTranscriptItemFromJson
TranscriptItem parseTranscriptItemFromJson(String jsonString)
-
-
-
-