flow_ktx

flow_ktx.kt

internal class TimelineRepositoryImpl @Inject constructor(
  private val databaseReference: DatabaseReference,
  private val json: Json
) : TimelineRepository {

  override fun fetchTimelineUi(): Flow<Result<TimelineUi?>> {
    return databaseReference.flow(
      path = { snapshot ->
        snapshot.child("timeline")
      },
      decodeProvider = { jsonString ->
        json.decodeFromString(jsonString)
      }
    )
  }
}