Skip to content

Commit

Permalink
Review fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
ivan-mashonskiy committed Oct 3, 2024
1 parent 2ff6c0f commit 4d9b42e
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 10 deletions.
16 changes: 8 additions & 8 deletions src/main/scala/units/client/contract/ContractBlock.scala
Original file line number Diff line number Diff line change
Expand Up @@ -7,14 +7,14 @@ import units.eth.EthAddress
import units.util.HexBytesConverter.toHex

case class ContractBlock(
hash: BlockHash,
parentHash: BlockHash,
epoch: Int,
height: Long,
feeRecipient: EthAddress,
chainId: Long,
e2cTransfersRootHash: Digest,
lastC2ETransferIndex: Long
hash: BlockHash,
parentHash: BlockHash,
epoch: Int,
height: Long,
feeRecipient: EthAddress,
chainId: Long,
e2cTransfersRootHash: Digest,
lastC2ETransferIndex: Long
) extends CommonBlockData {
override def toString: String =
s"ContractBlock($hash, p=$parentHash, e=$epoch, h=$height, m=$feeRecipient, c=$chainId, " +
Expand Down
4 changes: 2 additions & 2 deletions src/main/scala/units/network/MessageObserver.scala
Original file line number Diff line number Diff line change
@@ -1,13 +1,13 @@
package units.network

import com.wavesplatform.utils.{Schedulers, ScorexLogging}
import com.wavesplatform.utils.Schedulers
import io.netty.channel.ChannelHandler.Sharable
import io.netty.channel.{ChannelHandlerContext, ChannelInboundHandlerAdapter}
import monix.execution.schedulers.SchedulerService
import monix.reactive.subjects.{ConcurrentSubject, Subject}

@Sharable
class MessageObserver extends ChannelInboundHandlerAdapter with ScorexLogging {
class MessageObserver extends ChannelInboundHandlerAdapter {

private implicit val scheduler: SchedulerService = Schedulers.fixedPool(2, "message-observer-l2")

Expand Down

0 comments on commit 4d9b42e

Please sign in to comment.