sosuren

val g = RunnableGraph.fromGraph(GraphDSL.create() {
      implicit builder =>

        import GraphDSL.Implicits._

        val so = builder.add(Source.fromIterator(() => List(1, 2, 3).iterator)).out
        val p1 = builder.add(Flow[Int].scan(0)((acc, next) => acc + next))
        val p2 = builder.add(Flow[Int].delay(1.second))
        val b = builder.add(Broadcast[Int](2))
        val sa = builder.add(Sink.foreach[Int](item => {

sosuren

import akka.stream.stage.{InHandler, GraphStageLogic, GraphStage}
import sample.stream.AkkaStreamingSample.Gender.Gender

import scala.util.Random

object AkkaStreamingSample {
  import akka.actor.ActorSystem
  import akka.stream._
  import akka.stream.scaladsl._

sosuren

package wrappers

import play.api._
import play.api.mvc._
import scala.concurrent._
import scala.concurrent.Future
import play.mvc.Http.Status
import ExecutionContext.Implicits.global
import play.libs.Akka
import akka.actor.{Actor, Props}

sosuren

package wrappers

import play.api._
import play.api.mvc._
import scala.concurrent._
import scala.concurrent.Future
import play.mvc.Http.Status
import ExecutionContext.Implicits.global
import play.libs.Akka
import akka.actor.{Actor, Props}

sosuren

package com.deerwalk.das.scrub;

import cascading.flow.FlowProcess;
import cascading.operation.Aggregator;
import cascading.operation.AggregatorCall;
import cascading.operation.BaseOperation;
import cascading.tuple.Fields;
import cascading.tuple.Tuple;
import cascading.tuple.TupleEntry;