ndkoval
04/15/2023, 9:44 AMndkoval
04/15/2023, 9:44 AMCLOVIS
04/15/2023, 9:56 AMPetter Måhlén
05/10/2023, 9:09 AMpublic class FireAtLeastOnceConsumer<V>(
private val delegate: Consumer<V>,
) : Consumer<V> {
@Volatile
private var fired = false
public fun consumeIfFirst(value: V) {
if (!fired) {
consume(value)
}
}
override fun consume(data: V) {
fired = true
delegate.consume(data)
}
}
But I'm having a really hard time getting lincheck to find the problem. See thread for more details about what I've tried.