crypto_events_flow.scala

  Source
  
    // emits a GiveToken object once a day
    .tick(0.seconds, 1.day, GiveToken)

    // asks the Token Actor the auth token, is received as a string
    .mapAsync(1)(msg => (tokenActor ? msg) (3.seconds).mapTo[String])
    
    // passes it to the event request flow, implmented separately
    .via(eventRequestFlow)
    
    // unmarshal the results and maps it to my internal CoinEvent object
    .map(eventListUnmarshaller)
    .map(_.flatMap(EventAPI.toCoinEvents)))
    
    // publishes the result on Google Pub/Sub, implemented separately with Alpakka
    .via(eventPubSubFlow)
    
    // forwards the event list to the Coin Actor
    .runForeach(ev => coinActor ! ev)