DiegoRam

    val flowtoTest = Flow[Int].map(identity)

    val elOsito = Source.single(1)
      .via(flowtoTest)
      .toMat(sinkToTest)(Keep.right)
      .run()

    elOsito.onComplete {
      case Success(Done) => println("Hola wacho")
      case Failure(err) => println(s"te mataron por gato ${err.getMessage}")

DiegoRam

def getUser(id: Long): Future[User] = ???

/**
  * this is for pussies developers
  * @param ids
  * @return
  */
def getUsersBy(ids: Future[List[Long]]): Future[List[User]] =
  for {
    xs <- ids

DiegoRam

package service

import akka.actor.{ ActorLogging, Actor }
import api.Marshalling
import domain.{ CPTag, Note, Notification, Capture, User }
import org.joda.time.DateTime
import spray.json.ProductFormats
import core.DatabaseCfg._
import slick.driver.PostgresDriver.api._
import akka.pattern.pipe

DiegoRam

package com.capture.api.users

import io.gatling.core.Predef._
import io.gatling.http.Predef._
import Settings._


class OrganizationSimulation extends BaseSimulation{

DiegoRam

package api

import akka.actor.ActorSystem
import core.DefaultTimeout
import core.auth.authentication
import domain.User
import service.{ DeleteUser, GetUserById, SaveUser, UserFormat }
import spray.routing.Directives
import akka.pattern.ask
import spray.http.StatusCodes._

DiegoRam

package controllers

import auth.OAuthDataHandler
import core.models._
import play.Logger

import play.api._
import play.api.mvc._
import play.api.mvc.Results._
import play.api.libs.json._