Signal.send now returns tasks

src/effects.js

@@ -16,26 +16,21 @@ export function fromTask(task, successCallback, failureCallback) {
 }
 
 export function toTask(address, effect) {
-  return Rx.Observable.create(function toTaskObservable(observer) {
-    effect.subscribe(
-      action => {
-        Signal.send(address, action);
-        observer.onCompleted();
-      },
-      error => {
-        observer.onError(error);
-      }
-    );
-  });
+  return effect.flatMap(action => Signal.send(address, action));
 }
 
 export function merge(effects) {
   return Rx.Observable.merge(...effects);
 }
 
+export function sendAsEffect(address, msg, effMsg) {
+  return Signal.send(address, msg).map(() => effMsg);
+}
+
 export default {
   none,
   fromTask,
   toTask,
-  merge
+  merge,
+  sendAsEffect,
 };

src/html-events.js

@@ -59,7 +59,7 @@ export function decodeOn(decoder, options) {
     return on(
       options,
       decoder,
-      arg => Signal.send(address, handler(arg))
+      arg => Signal.sendSync(address, handler(arg))
     );
   };
 }
@@ -70,7 +70,7 @@ export function messageOn(options) {
     return on(
       options,
       R.identity,
-      ignoredArg => Signal.send(address, message)
+      ignoredArg => Signal.sendSync(address, message)
     );
   };
 }

src/signal.js

@@ -17,21 +17,28 @@ export function Mailbox(initialValue) {
   };
 }
 
-// forwardTo : (Address a, a -> a) -> a -> Task Never ()
+// send : (Address a, a) -> a -> Task Never ()
+export function send(address, message) {
+  return Rx.Observable.create(observer => {
+    address(message);
+    observer.onCompleted();
+  });
+}
+
 export function forwardTo(address, tagMessage) {
   return function forwardedAddress(message) {
-    return send(address, tagMessage(message));
+    return sendSync(address, tagMessage(message));
   };
 }
 
-// send : (Address a, a) -> a -> Task Never ()
-export function send(address, message) {
+export function sendSync(address, message) {
   address(message);
 }
 
 export default {
   Mailbox,
   forwardTo,
   send,
+  sendSync,
   merge
 };