blob: 810313c128abb65375c9d88f24254826e84f28d9 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
package org.terst.nav
import kotlinx.coroutines.flow.MutableSharedFlow
import kotlinx.coroutines.flow.SharedFlow
import org.terst.nav.sensors.WindData
class LocationService {
companion object {
private val _nmeaWindDataFlow = MutableSharedFlow<WindData>()
val nmeaWindDataFlow: SharedFlow<WindData> = _nmeaWindDataFlow
// line 362 — emit wind data parsed from NMEA sentences
suspend fun emitWind(wind: WindData) {
_nmeaWindDataFlow.emit(wind)
}
}
}
|