adamw

pragma solidity ^0.4.18;
import "./ERC20Interface.sol";
/**
 * Contract that will forward any incoming Ether to the creator of the contract
 */
contract Forwarder {
  // Address to which any funds sent to this contract will be forwarded
  address public parentAddress;
  event EthForwarded(address indexed from, address indexed to, uint256 value);

adamw

contract Sender {
  function () payable {}
  function transfer(address _receiver) payable {
    _receiver.transfer(100);
  }
}

adamw

adamw

def handleMessage(msg: CrawlerMessage, 
                  data: CrawlerData
                 ): IO[Nothing, CrawlerData] = msg match {
  case Start(url) =>
    crawlUrl(data, url)

  case CrawlResult(url, links) =>
    val data2 = data.copy(inProgress = data.inProgress - url)

    links.foldM(data2) {

adamw

def handleMessage(msg: CrawlerMessage, 
                  data: CrawlerData
                 ): IO[Nothing, CrawlerData] = msg match {
  case Start(url) =>
    crawlUrl(data, url)

  case CrawlResult(url, links) =>
    val data2 = data.copy(inProgress = data.inProgress - url)

    links.foldM(data2) {

adamw

def crawlUrl(data: CrawlerData, url: Url): IO[Nothing, CrawlerData] = {
  if (!data.visitedLinks.contains(url)) {
    workerFor(data, url.host).flatMap {
      case (data2, workerQueue) =>
        workerQueue.offer(url).map { _ =>
          data2.copy(
            visitedLinks = data.visitedLinks + url,
            inProgress = data.inProgress + url
          )
        }

adamw

override def receive: Receive = {
  case Crawl(url) =>
    // ...

  case HttpGetResult(url, Success(body)) =>
    getInProgress = false
    startHttpGetIfPossible()

    val links = parseLinks(body)
    master ! CrawlResult(url, links)

adamw

override def receive: Receive = {
  case Crawl(url) =>
    urlsPending = urlsPending :+ url
    startHttpGetIfPossible()
    
  // ...
}

private def startHttpGetIfPossible(): Unit = {
  urlsPending match {

adamw

override def receive: Receive = {
  case Start(start) =>
    crawlUrl(start)

  case CrawlResult(url, links) =>
    inProgress -= url

    links.foreach { link =>
      crawlUrl(link)
      referenceCount = referenceCount.updated(link.host, 

adamw

private def crawlUrl(url: Url): Unit = {
  if (!visitedLinks.contains(url)) {
    visitedLinks += url
    inProgress += url
    actorFor(url.host) ! Crawl(url)
  }
}

private def actorFor(host: Host): ActorRef = {
  workers.get(host) match {