Skip to content

Commit 11a0b77

Browse files
committed
Add type annotations
1 parent c3f165f commit 11a0b77

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

src/main/scala/io/iohk/ethereum/blockchain/sync/regular/BlockFetcher.scala

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,9 @@
11
package io.iohk.ethereum.blockchain.sync.regular
22

33
import akka.actor.Status.Failure
4-
import akka.actor.{Actor, ActorLogging, ActorRef, Props}
4+
import akka.actor.{Actor, ActorLogging, ActorRef, ActorSystem, Props}
55
import akka.pattern.{ask, pipe}
6-
import akka.stream.Attributes.InputBuffer
7-
import akka.stream.scaladsl.{Keep, Sink, Source}
6+
import akka.stream.scaladsl.{Keep, Sink, Source, SourceQueue}
87
import akka.stream.{Attributes, DelayOverflowStrategy, OverflowStrategy}
98
import akka.util.{ByteString, Timeout}
109
import cats.data.NonEmptyList
@@ -48,10 +47,10 @@ class BlockFetcher(
4847
import BlockFetcher._
4948

5049
implicit val ec: MonixScheduler = MonixScheduler(context.dispatcher)
51-
implicit val sys = context.system
50+
implicit val sys: ActorSystem = context.system
5251
implicit val timeout: Timeout = syncConfig.peerResponseTimeout + 2.second // some margin for actor communication
5352

54-
val queue = {
53+
private val queue: SourceQueue[BlockFetcherState] = {
5554
val cap = 1000
5655
val numberOfElements = 1
5756
Source

0 commit comments

Comments
 (0)