datalayer/com.google.android.horologist.data/WearDataLayerRegistry

WearDataLayerRegistry

class WearDataLayerRegistry(val dataClient: DataClient, val nodeClient: NodeClient, val messageClient: MessageClient, val capabilityClient: CapabilityClient, coroutineScope: CoroutineScope)

Implementation of Androidx Datastore for Proto and Preferences on top of the Wearable DataClient.

See https://developer.android.com/topic/libraries/architecture/datastore for DataStore features.

Constructors

constructor(dataClient: DataClient, nodeClient: NodeClient, messageClient: MessageClient, capabilityClient: CapabilityClient, coroutineScope: CoroutineScope)

Types

Companion

object Companion

Properties

capabilityClient

val capabilityClient: CapabilityClient

dataClient

val dataClient: DataClient

messageClient

val messageClient: MessageClient

nodeClient

val nodeClient: NodeClient

serializers

val serializers: SerializerRegistry

Functions

onDataChanged

fun onDataChanged(dataEvents: List<DataEvent>)

protoDataStore

fun <T> protoDataStore(path: String, coroutineScope: CoroutineScope, serializer: Serializer<T>, started: SharingStarted = SharingStarted.WhileSubscribed(5000)): DataStore<T>

Returns a local Proto DataStore for the given Proto structure.

protoDataStore

inline fun <T : Any> WearDataLayerRegistry.protoDataStore(coroutineScope: CoroutineScope): DataStore<T>

protoFlow

fun <T> protoFlow(targetNodeId: TargetNodeId, serializer: Serializer<T>, path: String): Flow<T>

protoFlow

inline fun <T : Any> WearDataLayerRegistry.protoFlow(node: TargetNodeId): Flow<T>

registerProtoDataListener

inline fun <T : Any> registerProtoDataListener(path: String, listener: ProtoDataListener<T>)

fun <T : Any> registerProtoDataListener(path: String, listener: ProtoDataListener<T>, serializer: Serializer<T>)

registerProtoDataListener

inline fun <T : Any> WearDataLayerRegistry.registerProtoDataListener(listener: ProtoDataListener<T>)

registerSerializer

inline fun <T : Any> registerSerializer(serializer: Serializer<T>)