diff --git a/src/main/scala/units/client/contract/ContractBlock.scala b/src/main/scala/units/client/contract/ContractBlock.scala index d056c971..25379605 100644 --- a/src/main/scala/units/client/contract/ContractBlock.scala +++ b/src/main/scala/units/client/contract/ContractBlock.scala @@ -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, " + diff --git a/src/main/scala/units/network/MessageObserver.scala b/src/main/scala/units/network/MessageObserver.scala index 709e798a..9b055f91 100644 --- a/src/main/scala/units/network/MessageObserver.scala +++ b/src/main/scala/units/network/MessageObserver.scala @@ -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")