This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import cats.{FlatMap, Monad} | |
import cats.data.StateT | |
import scala.concurrent.{Await, Future} | |
import scala.concurrent.duration._ | |
import scala.concurrent.ExecutionContext.Implicits.global | |
import scala.concurrent.duration.Duration | |
import cats.implicits._ | |
object ThrottleExp extends App { |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
object DbRepo { | |
sealed trait State | |
sealed trait Fresh extends State | |
sealed trait IndexCreated extends State | |
sealed trait IndexReady extends State | |
sealed trait ReadyToRead extends State | |
def apply(): DbRepo[Fresh] = new DbRepo | |
} |
NewerOlder