Represents session management, allowing multiple starts and ends while holding and atomically updating data. Notifies observers on data changes and supports synchronous or streaming data retrieval.
Surfaced from shared tags and platforms — no rankings paid for.
Session class represents a concept of a session:
data flow),⚠ Be aware that
dataflow is conflated. If it is important that no item is missed the flow should be subscribed usingDispatchers.Unconfineddispatcher.
It is also a good idea to start the subscription usingCoroutineStart.UNDISPATCHEDstart method - otherwise the subscription may not be synchronous.
internal class LoginSession : Session<LoginSessionData>()
internal data class LoginSessionData(
val username: String,
val password: String
)
val domainModule = module {
...
singleOf(::LoginSession)
...
}
ℹ You must always provide initial data while starting session.
class BeginLoginProcessUseCase internal constructor(
private val loginSession: LoginSession
) {
operator fun invoke() {
if (!loginSession.isStarted) {
loginSession.start(LoginSessionData("", ""))
}
}
}
class UpdateCollectedUsernameUseCase internal constructor(
private val loginSession: LoginSession
) {
operator fun invoke(username: String) {
loginSession.update { sessionData ->
sessionData.copy(username = username)
}
}
}
class GetAccessTokenUseCase internal constructor(
private val loggedInSession: LoggedInSession
) {
operator fun invoke(): String = loggedInSession.requireData().accessToken
}
class GetCollectedUsernameUseCase internal constructor(
private val loginSession: LoginSession
) {
operator fun invoke(): Flow<String> = loginSession.data.map { data -> data!!.username }
}
class IsCollectedUsernameFormatValidUseCase internal constructor(
loginSession: LoginSession
) {
: Flow<UsernameValidationResult> = loginSession
.
.map { sessionData ->
sessionData?.username?.let { username ->
length = username.length
{
length == -> NOT_AVAILABLE
length < -> TOO_SHORT
length > -> TOO_LONG
-> VALID
}
} ?: NOT_AVAILABLE
}
}
{
NOT_AVAILABLE,
TOO_SHORT,
TOO_LONG,
VALID
}
class AbortLoginProcessUseCase internal constructor(
private val loginSession: LoginSession
) {
operator fun invoke() {
if (loginSession.isStarted) {
loginSession.end()
}
}
}
internalsingleOf in Koin)Start_XXX_SessionUseCase