OutWatch/Lobby

elyphas

@elyphas

outwatch.reactive.handler._

import outwatch.reactive.handler._

Aleksandr Bogdanov

@laniakea-landscape_gitlab

my imports right now:

import cats.effect.ExitCode

import monix.execution.Scheduler
import monix.{eval => me}
import monix.bio._

import outwatch._
import outwatch.dsl._
import outwatch.reactive.handler._

import sttp.client3._
import sttp.client3.impl.monix.FetchMonixBackend
import sttp.capabilities.monix.MonixStreams

import java.util.concurrent.TimeUnit
import scala.concurrent.duration.Duration

I can use val handlerTask = Handler.createF[monix.bio.Task, String] without seed

Aleksandr Bogdanov

@laniakea-landscape_gitlab

But then I still need implicit for Sync[IO] parameter

And somehow not found mapEval here:

handler
    .doOnNext(str => me.Task(println(str)))
    .mapEval(query => request(query))

That is why I am interested why @rohan-sircar s code works)

elyphas

@elyphas

Maybe:

import cats.implicits._

Aleksandr Bogdanov

@laniakea-landscape_gitlab

I had imports from cats and cats.effets implicits

elyphas

@elyphas

import monix.eval.Task

Aleksandr Bogdanov

@laniakea-landscape_gitlab

nope

Rohan Sircar

@rohan-sircar

You need to import import outwatch.reactive.handlers.monix._

Here are all of my imports just in case https://pastebin.com/3zm6eZTg

Rohan Sircar

@rohan-sircar

Btw everyone my PR to update outwatch router to latest versions of scala/outwatch got merged - clovellytech/outwatch-router#9 . So there's a functioning router for outwatch now.

goes back to sleep

Aleksandr Bogdanov

@laniakea-landscape_gitlab

Here are all of my imports just in case https://pastebin.com/3zm6eZTg

No way =( It compiles after addition of this:

    def scheduler: Scheduler = Scheduler.global
    def options: IO.Options  = IO.defaultOptions.withSchedulerFeatures(scheduler)
    implicit lazy val catsEffect: ConcurrentEffect[Task] =
      new CatsConcurrentEffectForTask()(scheduler, options)

But nothing on the screen, unfortunately. Even no input field.

elyphas

@elyphas

@laniakea-landscape_gitlab; Are you sure your div id in your html correspond where outwatch is going to render?

Aleksandr Bogdanov

@laniakea-landscape_gitlab

@elyphas Sure. Checked it again.

Rohan Sircar

@rohan-sircar

@laniakea-landscape_gitlab you definitely don't need any of that. I'll upload my project tomorrow.

Rohan Sircar

@rohan-sircar

@laniakea-landscape_gitlab https://github.com/rohan-sircar/Outwatch-Sttp-Example

Rohan Sircar

@rohan-sircar

@laniakea-landscape_gitlab well? did it work?

Raphael Mäder

@randm-ch

Hello there. I'm trying to get into outwatch. It seems to me that the docs are a bit outdated, what's the most recent/best source?
In particular, at the moment I want to get a simple example to work:

import cats.effect._
import outwatch._
import outwatch.dsl._
import outwatch.reactive.handler._
import outwatch.util._
import scala.concurrent.ExecutionContext.Implicits.global

object Main extends IOApp {
  private val app = for {
    hdl <- Handler.createF[IO]("")
    qry <- IO.pure(hdl.map(query => Http.Request(s"https://someurl.org?query=$query")))
    res <- IO(Http.get(qry).map(_.body))
    xml <- IO.pure(div(
      input(onInput.value --> hdl),
      span(child <-- res)
    ))
    rnd <- OutWatch.renderInto[IO]("#app", xml)
  } yield rnd

  override def run(args: List[String]): IO[ExitCode] =
    app.as(ExitCode.Success)
}

but child is not available. Am I missing an import? Or did something change? Thanks!

johannes karoff

@cornerman

Hi @randm-ch , yeah the docs on the outwatch page are a bit outdated. Please refer to the github readme. The documentation there is up to date.

I will have to do something about the old webpage and remove the outdated content there.

For the question here: you can just leave out the child <-- and just put the observable into the element directly: span(res)

Raphael Mäder

@randm-ch

Perfect, thanks a bunch for the info & all your work :)

Aleksandr Bogdanov

@laniakea-landscape_gitlab

@laniakea-landscape_gitlab well? did it work?

@rohan-sircar Sorry for silence, I will look in several days. Was extremely busy last weeks.

Per Wiklander

@PerWiklander

Has anyone used Akka.js and Akka Streams and Actors for the state handling layer of an Outwatch application?

moritz bust

@busti

@PerWiklander I haven't used akka specifically, but what I am trying to do is very similar to akka. But that comes from a person who has little to no experience with akka.
That being said, I am very interested in that discussion in general.

johannes karoff

@cornerman

@PerWiklander Never did that, but I guess using akka streams and actors in outwatch should be quite straight forward. We have a typeclass Source and a typeclass Sink. You should be able to implement them with Stream and Actor respectively. Then you can use them in the outwatch dsl.

Sait Sami Kocataş

@Deliganli

hi everyone, how could I use a canvas, update it with observable (or fs2.Stream)?

johannes karoff

@cornerman

Hi there, what exactly do you want to do with the canvas? They are a bit tricky. I did this to be able to paint a chart inside of it:

    canvas(
      managedElement { elem =>
        val context = elem.asInstanceOf[dom.html.Canvas].getContext("2d").asInstanceOf[org.scalajs.dom.raw.CanvasRenderingContext2D]
        // do something with context

        cancelable(() => /*destroy something*/)
      }
    )

Does that help?

Sait Sami Kocataş

@Deliganli

thanks @cornerman I will try it out when possible :)
I was gonna draw some circles and update their position etc based on an event stream, thinking to do this in a canvas. I have no idea how frontend works honestly, just trying out.

elyphas

@elyphas

Hi, is there a way to not trigger an event when the app start? in this code:

  def getId = ( hdlFiscalPeriod: Observable[Int], hdlFolio: Observable[String])
        .parMapN { case (fiscal_period: Int, folio: String) => (fiscal_period,  folio) }

onInput
            .value
            .debounce(800 milliseconds)
            .transformLifted{ e: Observable[String] =>
              e
                .distinctUntilChanged
                .debounce(800 milliseconds)
                .withLatestFrom(getId) {case (txt@_, idCreditStoreDocument) =>
                    println("#################################")
                    idCreditStoreDocument
                }
} --> repo.eventListItems

The problem I have is that repo.eventListItems is making the query but with one data and I need two.
I tried filter after debounce but it is ignore
I have two inputs and one is by default.
year and number the year is by default so this is year is triggering the event. at the start of the app.

Felix Dietze

@fdietze

:tada: I finally found the time to update the readme and website of outwatch: https://github.com/outwatch/outwatch and https://outwatch.github.io/docs/readme.html
Let me know what you think :)

moritz bust

@busti

Cheers :tada:

moritz bust

@busti

@fdietze The examples look really good

Felix Dietze

@fdietze

Thank you :)

ioleo

@ioleo

Hi, I'm need an event handler to access the elemet's scrollTop position, but can't figure out how. I've tried:

import outwatch._
import outwatch.dsl._
import org.scalajs.dom.raw.HTMLElement
import zio.Task
import zio.interop.catz._

object Header {
  def apply(): HtmlVNode = {
    val logo = Task {
      val isDetached = events.document.onScroll.map { e =>
        val scrollTop = e.target.asInstanceOf[HTMLElement].scrollTop
        println(s"top dist = $scrollTop")
        if (scrollTop > 50) "detached" else "attached"
      }.debounceMillis(250)

      div(
       // ...
         className <- isDetached
       )
    }
    div(logo)
  }
}

ioleo

@ioleo

However it throws at runtime. I guess the asInstanceOf is wrong. What would be the correct way?

ioleo

@ioleo

Alright I see now why it fails e.target is actually HTMLDocument.

ioleo

@ioleo

For future reference, the solution is:


    val fixedOnScroll = events.document.onScroll.debounceMillis(100).map { e =>
      val documentElement = e.target.asInstanceOf[HTMLDocument]
      val scrollDistance = documentElement.documentElement.scrollTop
      if (scrollDistance > 50) VDomModifier(position.fixed, left := "50%", marginLeft := "-250px")
      else VDomModifier(position.relative, left := "auto", marginLeft := "auto")
    }

    div(
      // ...
      fixedOnScroll
    )

moritz bust

@busti

Glad to hear that you found a solution.

Aleksandr

@steakoverflow-me

Hello to all!

Hi, I'm need an event handler to access the elemet's scrollTop position, but can't figure out how. I've tried:

import outwatch._
import outwatch.dsl._
import org.scalajs.dom.raw.HTMLElement
import zio.Task
import zio.interop.catz._

object Header {
  def apply(): HtmlVNode = {
    val logo = Task {
      val isDetached = events.document.onScroll.map { e =>
        val scrollTop = e.target.asInstanceOf[HTMLElement].scrollTop
        println(s"top dist = $scrollTop")
        if (scrollTop > 50) "detached" else "attached"
      }.debounceMillis(250)

      div(
       // ...
         className <- isDetached
       )
    }
    div(logo)
  }
}

I can't get how you made it to work? I mean div(logo) when logo is the zio.Task. For me there is a error like

Found: (logo : zio.Task[outwatch.HtmlVNode]) 
Required: outwatch.VDomModifier

Felix Dietze

@fdietze

@steakoverflow-me I think ZIO Task is not supported yet. Use IO or Monix Task instead. @cornerman used to work on ZIO support, but it's not merged yet: outwatch/outwatch#442

johannes karoff

@cornerman

You should be able to use https://github.com/zio/interop-cats, because it gives you an Effect instance for zio tasks. You get this implicit via the import: import zio.interop.catz._. Though you need an implicit runtime in the scope.
As @fdietze pointed out, we are currently working on a better zio support in the PR, but i think, it might need some more time to be merged. Until then interop-cats is the way to go.

Where communities thrive

People

Repo info

Activity