Skip to content

Commit

Permalink
Format
Browse files Browse the repository at this point in the history
  • Loading branch information
ofekby committed Nov 22, 2023
1 parent 66cf175 commit 6d8a186
Showing 1 changed file with 1 addition and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -11,9 +11,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock
import java.util.function.Consumer

open class TopicBasedState<T, S : Consumer<T>>(
private val topic: Topic<S>,
@Volatile
private var value: T? = null
private val topic: Topic<S>, @Volatile private var value: T? = null
) {
private val rwLock: ReadWriteLock = ReentrantReadWriteLock()
private val hasChanged = AtomicBoolean(false)
Expand Down

0 comments on commit 6d8a186

Please sign in to comment.