RustSpaceService.joinedSpaces() now points to the FFI method SpaceService.topLevelJoinedSpaces()
This commit is contained in:
parent
cfa7d39966
commit
293d41f122
1 changed files with 2 additions and 2 deletions
|
|
@ -51,7 +51,7 @@ class RustSpaceService(
|
||||||
|
|
||||||
override suspend fun joinedSpaces(): Result<List<SpaceRoom>> = withContext(sessionDispatcher) {
|
override suspend fun joinedSpaces(): Result<List<SpaceRoom>> = withContext(sessionDispatcher) {
|
||||||
runCatchingExceptions {
|
runCatchingExceptions {
|
||||||
innerSpaceService.joinedSpaces()
|
innerSpaceService.topLevelJoinedSpaces()
|
||||||
.map {
|
.map {
|
||||||
it.let(spaceRoomMapper::map)
|
it.let(spaceRoomMapper::map)
|
||||||
}
|
}
|
||||||
|
|
@ -97,7 +97,7 @@ internal fun SpaceServiceInterface.spaceListUpdate(): Flow<List<SpaceListUpdate>
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
Timber.d("Open spaceDiffFlow for SpaceServiceInterface ${this@spaceListUpdate}")
|
Timber.d("Open spaceDiffFlow for SpaceServiceInterface ${this@spaceListUpdate}")
|
||||||
val taskHandle = subscribeToJoinedSpaces(listener)
|
val taskHandle = subscribeToTopLevelJoinedSpaces(listener)
|
||||||
awaitClose {
|
awaitClose {
|
||||||
Timber.d("Close spaceDiffFlow for SpaceServiceInterface ${this@spaceListUpdate}")
|
Timber.d("Close spaceDiffFlow for SpaceServiceInterface ${this@spaceListUpdate}")
|
||||||
taskHandle.cancelAndDestroy()
|
taskHandle.cancelAndDestroy()
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue