tarsa

// in test source directory

object LocalSetup { // for running app locally
  private val localConfig = ???
  val instance = new ApplicationSetup(Some(localConfig)).instance
}

// in main source directory
object ProductionSetup extends ApplicationSetup(None)

tarsa

package futseq

import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.duration.Duration
import scala.concurrent.{Await, Future}
import scala.language.implicitConversions

object FutSeq {
  sealed trait HList

tarsa

package akka.stream

import akka.{Done, NotUsed}
import akka.stream.scaladsl.{Flow, Source}
import akka.stream.stage._
import akka.util.ByteString

import scala.concurrent.{Future, Promise}

final class ReconnectingProxy[T, M](