Skip to content

Commit 51f585a

Browse files
committed
Better code
1 parent 861be8f commit 51f585a

File tree

1 file changed

+5
-7
lines changed

1 file changed

+5
-7
lines changed

node/src/main/scala/com/wavesplatform/mining/microblocks/MicroBlockMinerImpl.scala

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -143,19 +143,17 @@ class MicroBlockMinerImpl(
143143
account: KeyPair,
144144
block: Block,
145145
transactions: Seq[Transaction],
146-
updatedTotalConstraint: MiningConstraint,
146+
constraint: MiningConstraint,
147147
stateHash: Option[BlockId]
148148
): Task[MicroBlockMiningResult] =
149149
for {
150-
(signedBlock, microBlock) <- forgeBlocks(account, block, transactions, stateHash)
151-
.leftWiden[Throwable]
152-
.liftTo[Task]
153-
blockId <- appendMicroBlock(microBlock)
150+
(signedBlock, microBlock) <- forgeBlocks(account, block, transactions, stateHash).leftWiden[Throwable].liftTo[Task]
151+
blockId <- appendMicroBlock(microBlock)
154152
_ = BlockStats.mined(microBlock, blockId)
155153
_ <- broadcastMicroBlock(account, microBlock, blockId)
156154
} yield
157-
if (updatedTotalConstraint.isFull) Stop
158-
else Success(signedBlock, updatedTotalConstraint)
155+
if (constraint.isFull) Stop
156+
else Success(signedBlock, constraint)
159157

160158
private def broadcastMicroBlock(account: KeyPair, microBlock: MicroBlock, blockId: BlockId): Task[Unit] =
161159
Task(if (allChannels != null) allChannels.broadcast(MicroBlockInv(account, blockId, microBlock.reference)))

0 commit comments

Comments
 (0)