Attention: the list was moved to
https://github.com/dypsilon/frontend-dev-bookmarks
This page is not maintained anymore, please update your bookmarks.
Attention: the list was moved to
https://github.com/dypsilon/frontend-dev-bookmarks
This page is not maintained anymore, please update your bookmarks.
import java.lang.Math.*; | |
public class Progressbar { | |
private int max; | |
private int current; | |
private String name; | |
private long start; | |
private long lastUpdate; | |
public Progressbar(int max, String name) |
import sbt._ | |
import Keys._ | |
object Build extends sbt.Build { | |
val unmanagedJars = TaskKey[Keys.Classpath]("unmanaged-jars") | |
unmanagedJars := { | |
Configuration.listUnmanaged( file(".").getAbsoluteFile ) | |
} |
package app.actors | |
import akka.event.Logging | |
import akka.http.scaladsl._ | |
import akka.http.scaladsl.model.HttpHeader.ParsingResult | |
import akka.http.scaladsl.model._ | |
import akka.stream.ActorMaterializer | |
import akka.typed.ScalaDSL._ | |
import akka.typed._ | |
import argonaut.Argonaut._ |
package app.actors | |
import akka.actor.{Actor, ActorLogging} | |
import argonaut._, Argonaut._ | |
import infrastructure.GCM | |
import launch.RTConfig | |
import spray.client.pipelining._ | |
import spray.http._ | |
import spray.httpx.marshalling.Marshaller |
Using: | |
* 8 threads | |
* 1024 concurrent connections | |
* run for 20 seconds | |
* 64 requests pipelined | |
## VERTX | |
norman@dev-linux:~/workspace/vertx-examples/src/main/java$ vertx run httpperf/PerfServer.java -instances 4 |
package fpmax | |
import scala.util.Try | |
import scala.io.StdIn.readLine | |
object App0 { | |
def main: Unit = { | |
println("What is your name?") | |
val name = readLine() |
I'm a long time user of reactive streams in Scala. Originally with akka-streams, and then Monix Observable.
The transition from akka streams to Monix Observable I found pretty straight forward. I was motivated by wanting to use a lazy effect system, rather than working with scala.concurrent.Future
.
More recently I've been considering fs2 and Zio Streams as an alternative to Monix Observable. This has largely been motivated by the fact that Monix doesn't have much ongoing development and is stuck on cats-effect 2.
I've not found the transition from Monix Observable to Zio Streams as easy as my earlier transition (from akka -> monix). While the ergonomics of the API are similar, performance characterics differ hugely.