Browse Source

Organized Imports

master
Rohan Sircar 3 years ago
parent
commit
4b7c3e633b
  1. 10
      src/main/scala/outwatch/router/Router.scala
  2. 6
      src/main/scala/outwatch/router/dsl/Path.scala
  3. 2
      src/main/scala/outwatch/router/package.scala
  4. 15
      src/main/scala/outwatch/util/MonixWebSocket.scala
  5. 7
      src/main/scala/outwatch/util/WebSocket2.scala
  6. 24
      src/main/scala/outwatchapp/OutwatchApp.scala
  7. 10
      src/main/scala/outwatchapp/implicits/package.scala
  8. 4
      src/main/scala/outwatchapp/util/reactive/store/Middlewares.scala

10
src/main/scala/outwatch/router/Router.scala

@ -1,15 +1,15 @@
package outwatch.router
import org.scalajs.dom.window
import colibri.Observable
import outwatch.util.Store
import outwatch.util.Reducer
import cats.effect.Sync
import colibri.Observable
import org.scalajs.dom.window
import outwatch._
import outwatch.dsl._
import outwatch.router.dsl.Path
import outwatch.router.dsl.HashPath
import outwatch.router.dsl.Path
import outwatch.router.dsl.Root
import outwatch.util.Reducer
import outwatch.util.Store
sealed trait Action
final case class Replace(path: Path) extends Action

6
src/main/scala/outwatch/router/dsl/Path.scala

@ -2,11 +2,13 @@
package outwatch.router.dsl
import cats.implicits._
import java.nio.{ByteBuffer, CharBuffer}
import java.nio.ByteBuffer
import java.nio.CharBuffer
import java.nio.charset.Charset
import java.nio.charset.StandardCharsets.UTF_8
import cats.implicits._
/** Base class for path extractors. */
trait Path {
def /(child: String): Path = new /(this, child)

2
src/main/scala/outwatch/router/package.scala

@ -1,7 +1,7 @@
package outwatch
import outwatch._
import colibri.ProSubject
import outwatch._
package object router {
type RouterStore[P] = ProSubject[Action, (Action, RouterState[P])]

15
src/main/scala/outwatch/util/MonixWebSocket.scala

@ -1,16 +1,17 @@
package outwatch.util
import outwatch.helpers._
// import colibri._
import org.scalajs.dom.{Event, MessageEvent}
import scala.concurrent.Future
import cats.Show
import cats.effect.Sync
import monix.execution.Ack
import monix.execution.Cancelable
import monix.reactive.Observable
import monix.reactive.Observer
import monix.execution.Cancelable
import monix.reactive.OverflowStrategy
import scala.concurrent.Future
import monix.execution.Ack
import cats.Show
import org.scalajs.dom.Event
import org.scalajs.dom.MessageEvent
import outwatch.helpers._
object MonixWS {
// implicit def toObserver[F[_]: Sync, S: Show](

7
src/main/scala/outwatch/util/WebSocket2.scala

@ -1,9 +1,10 @@
package outwatch.util
import outwatch.helpers._
import colibri._
import org.scalajs.dom.{Event, MessageEvent}
import cats.effect.Sync
import colibri._
import org.scalajs.dom.Event
import org.scalajs.dom.MessageEvent
import outwatch.helpers._
object WebSocketF {
implicit def toObserver[F[_]: Sync](

24
src/main/scala/outwatchapp/OutwatchApp.scala

@ -1,24 +1,24 @@
package outwatchapp
import outwatch._
import outwatch.dsl._
import scala.concurrent.duration._
import cats.effect.ExitCode
import monix.bio._
import cats.implicits._
import colibri.ext.monix._
import monix.bio._
import monix.eval.Coeval
import monix.reactive.Observable
import scala.concurrent.duration._
import cats.implicits._
import outwatch.router.AppRouter
import outwatch.router.dsl._
import sttp.client.impl.monix.FetchMonixBackend
import outwatch.reactive.handlers.monix._
import sttp.client._
import monix.{eval => me}
import nova.monadic_sfx.ui.components.todo.Todo
import nova.monadic_sfx.ui.components.todo.TodoListStore
import outwatch._
import outwatch.dsl._
import outwatch.reactive.handlers.monix._
import outwatch.router.AppRouter
import outwatch.router.dsl._
import outwatchapp.implicits._
import monix.eval.Coeval
import nova.monadic_sfx.ui.components.todo.Todo
import sttp.client._
import sttp.client.impl.monix.FetchMonixBackend
object OutwatchApp extends BIOApp {
val counter2 = Observable.interval(1.second)

10
src/main/scala/outwatchapp/implicits/package.scala

@ -1,17 +1,11 @@
package outwatchapp
import colibri.Sink
import nova.monadic_sfx.util.reactive.store.MonixProSubject
import cats.effect.Sync
import colibri.CreateProSubject
import colibri.Source
import colibri.LiftSink
import monix.reactive.Observer
import colibri.LiftSource
import monix.reactive.Observable
import colibri.ext.monix._
import monix.execution.Scheduler
import monix.execution.Ack
import monix.reactive.Observable
import monix.reactive.Observer
package object implicits {
// implicit def sinkForMyMonixProSub[A, M] =

4
src/main/scala/outwatchapp/util/reactive/store/Middlewares.scala

@ -2,12 +2,8 @@ package nova.monadic_sfx.util.reactive.store
import java.time.LocalDateTime
import io.circe.Encoder
import io.circe.Printer
import io.circe.generic.JsonCodec
import io.circe.syntax._
import monix.bio.Task
import monix.reactive.Observable
// object Middleware {
// def apply[A,M,T](ob: Observable[(A,M)], cb: (A,M) => T): Observable[(A,M)] = ob
// }

Loading…
Cancel
Save