diff --git a/we-atomic/src/main/kotlin/com/wavesenterprise/sdk/atomic/AtomicBroadcaster.kt b/we-atomic/src/main/kotlin/com/wavesenterprise/sdk/atomic/AtomicBroadcaster.kt index 15cffcd9..a1efa2d4 100644 --- a/we-atomic/src/main/kotlin/com/wavesenterprise/sdk/atomic/AtomicBroadcaster.kt +++ b/we-atomic/src/main/kotlin/com/wavesenterprise/sdk/atomic/AtomicBroadcaster.kt @@ -12,7 +12,7 @@ class AtomicBroadcaster( ) { private val txService: TxService = atomicAwareNodeBlockingServiceFactory.txService() - fun doInAtomic(block: () -> T): T? { + fun doInAtomic(block: () -> T): T { atomicAwareContextManager.beginAtomic() try { val blockResult = block()