New: mapToUnit; some Airstream aliases

raquo · Oct 1, 2022 · caa0448 · caa0448
1 parent 05e4447
commit caa0448
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/src/main/scala/com/raquo/laminar/api/Airstream.scala b/src/main/scala/com/raquo/laminar/api/Airstream.scala
@@ -66,12 +66,24 @@ trait Airstream {
 
   val DynamicSubscription: airstream.ownership.DynamicSubscription.type = airstream.ownership.DynamicSubscription
 
+  // -- Special streams
+
+  lazy val AjaxStream: airstream.web.AjaxStream.type = airstream.web.AjaxStream
+
+  lazy val FetchStream: airstream.web.FetchStream.type = airstream.web.FetchStream
+
   // -- Flatten
 
   type FlattenStrategy[-Outer[+_] <: Observable[_], -Inner[_], Output[+_] <: Observable[_]] = airstream.flatten.FlattenStrategy[Outer, Inner, Output]
 
   lazy val SwitchStreamStrategy: airstream.flatten.FlattenStrategy.SwitchStreamStrategy.type = airstream.flatten.FlattenStrategy.SwitchStreamStrategy
 
+  lazy val ConcurrentStreamStrategy: airstream.flatten.FlattenStrategy.ConcurrentStreamStrategy.type = airstream.flatten.FlattenStrategy.ConcurrentStreamStrategy
+
+  lazy val SwitchSignalStreamStrategy: airstream.flatten.FlattenStrategy.SwitchSignalStreamStrategy.type = airstream.flatten.FlattenStrategy.SwitchSignalStreamStrategy
+
   lazy val SwitchSignalStrategy: airstream.flatten.FlattenStrategy.SwitchSignalStrategy.type = airstream.flatten.FlattenStrategy.SwitchSignalStrategy
 
+  lazy val SwitchSignalObservableStrategy: airstream.flatten.FlattenStrategy.SwitchSignalObservableStrategy.type = airstream.flatten.FlattenStrategy.SwitchSignalObservableStrategy
+
 }
diff --git a/src/main/scala/com/raquo/laminar/keys/EventProcessor.scala b/src/main/scala/com/raquo/laminar/keys/EventProcessor.scala
@@ -135,6 +135,8 @@ class EventProcessor[Ev <: dom.Event, V](
     withNewProcessor(ev => processor(ev).map(_ => value))
   }
 
+  def mapToUnit: EventProcessor[Ev, Unit] = mapToStrict(())
+
   /** Get the original event. You might want to call this in a chain, after some other processing. */
   def mapToEvent: EventProcessor[Ev, Ev] = {
     withNewProcessor(ev => processor(ev).map(_ => ev))