ProtoDataStore5.kt

object EmployeePreferencesSerializer : Serializer<EmployeePreference> {
    override val defaultValue: EmployeePreference = EmployeePreference.getDefaultInstance()

    @Suppress("BlockingMethodInNonBlockingContext")
    override suspend fun readFrom(input: InputStream): EmployeePreference {
        try {
            return EmployeePreference.parseFrom(input)
        } catch (exception: InvalidProtocolBufferException) {
            throw CorruptionException("Cannot read proto.", exception)
        }
    }

    @Suppress("BlockingMethodInNonBlockingContext")
    override suspend fun writeTo(t: EmployeePreference, output: OutputStream) = t.writeTo(output)
}