Skip to content

Instantly share code, notes, and snippets.

View MartinHH's full-sized avatar

Martin Hansen MartinHH

7 followers · 0 following
  • Hamburg, Germany
View GitHub Profile
@MartinHH
MartinHH / SwitchMap.scala
Last active December 15, 2018 15:37
RxScala vs Monix(3.0.0-RC2): behavior of SwitchMap when "parent" Observable completes
package example
import monix.execution.Ack
object Main {
def main(args: Array[String]): Unit = {
implicit val s = monix.execution.schedulers.TestScheduler()
val parent = monix.reactive.subjects.PublishSubject[Int]()
val child = monix.reactive.subjects.PublishSubject[Int]()
@MartinHH
MartinHH / WeightExample.scala
Last active April 8, 2016 05:03
Code example for https://stackoverflow.com/questions/36416723/group-stream-elements-by-weight-function-in-akka-streams/36437850#36437850
package example
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl._
object WeightExample {
def main(args: Array[String]) {
@MartinHH
MartinHH / Sieve.scala
Last active April 3, 2016 20:40
Code example for https://stackoverflow.com/questions/36381603/how-can-i-modify-my-akka-streams-prime-sieve-to-exclude-modulo-checks-for-known
package example
import akka.actor.ActorSystem
import akka.stream.scaladsl._
import akka.stream.{ClosedShape, ThrottleMode, ActorMaterializerSettings, ActorMaterializer}
import scala.collection.immutable.SortedSet
import scala.concurrent.duration._
import scala.concurrent.ExecutionContext
import scala.language.postfixOps