tuweni / org.apache.tuweni.eth.crawler / CrawlerApplication

CrawlerApplication

class CrawlerApplication : CoroutineScope (source)

Constructors

<init>

CrawlerApplication(vertx: Vertx, config: CrawlerConfig, coroutineContext: CoroutineDispatcher = Executors.newFixedThreadPool(
      config.numberOfThreads()
    ) {
      val thread = Thread("crawler")
      thread.isDaemon = true
      thread
    }.asCoroutineDispatcher())

Properties

config	`val config: CrawlerConfig`
coroutineContext	`val coroutineContext: CoroutineDispatcher`
vertx	`val vertx: Vertx`

Functions

connect	`fun connect(rlpxService: RLPxService, key: PublicKey, address: InetSocketAddress): AsyncCompletion`
createCoroutineContext	`fun createCoroutineContext(): ExecutorCoroutineDispatcher`
run	`fun run(): Unit`

CrawlerApplication

Constructors

<init>

Properties

config

coroutineContext

vertx

Functions

connect

createCoroutineContext

run