Initial Commit

Author: davidwdan

.gitignore

@@ -0,0 +1,5 @@
+phpunit.xml
+composer.lock
+vendor/
+.idea
+.DS_STORE

README.md

@@ -0,0 +1,22 @@
+===============
+Helper Functions for RxPHP
+===============
+
+```PHP
+Observable::of(Observable::fromArray([1, 2, 3, 4, 5]))
+    ->filter(\Rx\is(Observable::class))
+    ->mergeAll()
+    ->filter(\Rx\notEqualTo(2))
+    ->filter('rx\even')
+    ->reduce('rx\add')
+    ->map(\Rx\p('rx\mult', 3))
+    ->map(\Rx\p('rx\sub', 2))
+    ->map(\Rx\p('rx\concatLeft', 'total: '))
+    ->compose(\Rx\echoFinally('Test '))
+    ->subscribe(\Rx\echoObserver('Test '));
+
+
+//Test Next value: total: 10
+//Test Complete!
+//Test Finally! 
+```

composer.json

@@ -0,0 +1,38 @@
+{
+  "name": "rx/helpers",
+  "type": "library",
+  "description": "A collection of functions to use with RxPHP",
+  "keywords": [
+    "rx",
+    "rx.php",
+    "rxphp",
+    "react",
+    "reactive"
+  ],
+  "license": "MIT",
+  "authors": [
+    {
+      "name": "Matt Bonneau",
+      "email": "[email protected]",
+      "role": "Developer"
+    },
+    {
+      "name": "David Dan",
+      "email": "[email protected]",
+      "role": "Developer"
+    }
+  ],
+  "autoload": {
+    "psr-4": {
+      "Rx\\Websocket\\": "src/"
+    }
+  },
+  "require": {
+    "reactivex/rxphp": "^2.0"
+  },
+  "autoload": {
+    "files": [
+      "src/functions.php"
+    ]
+  }
+}

src/functions.php

@@ -0,0 +1,132 @@
+<?php
+
+namespace Rx;
+
+use Rx\Observer\CallbackObserver;
+
+function is($class): callable
+{
+    return function ($value) use ($class): bool {
+        return is_a($value, $class);
+    };
+}
+
+function equalTo($a): callable
+{
+    return function ($b) use ($a): bool {
+        return $a == $b;
+    };
+}
+
+function notEqualTo($a): callable
+{
+    return function ($b) use ($a): bool {
+        return $a != $b;
+    };
+}
+
+function same($a): callable
+{
+    return function ($b) use ($a): bool {
+        return $a === $b;
+    };
+}
+
+function notSame($a): callable
+{
+    return function ($b) use ($a): bool {
+        return $a !== $b;
+    };
+}
+
+function add($accum, $value)
+{
+    return $accum + $value;
+}
+
+function concat($accum, $value): string
+{
+    return $accum . $value;
+}
+
+function concatLeft($accum, $value): string
+{
+    return $value . $accum;
+}
+
+function sub($accum, $value)
+{
+    return $accum - $value;
+}
+
+function mult($accum, $value)
+{
+    return $accum * $value;
+}
+
+function echoLine($value)
+{
+    echo $value, PHP_EOL;
+}
+
+function odd($number)
+{
+    return $number % 2 !== 0;
+}
+
+function even($number)
+{
+    return $number % 2 === 0;
+}
+
+function echoObserver($prefix = '')
+{
+    return new CallbackObserver(
+        function ($value) use ($prefix) {
+            echo $prefix . 'Next value: ' . asString($value) . PHP_EOL;
+        },
+        function (\Throwable $error) use ($prefix) {
+            echo $prefix . 'Exception: ' . $error->getMessage() . PHP_EOL;
+        },
+        function () use ($prefix) {
+            echo $prefix . 'Complete! ' . PHP_EOL;
+        }
+    );
+}
+
+function echoFinally($prefix = ''): callable
+{
+    return function (Observable $observable) use ($prefix): Observable {
+        return $observable->finally(function () use ($prefix) {
+            echo $prefix . 'Finally! ' . PHP_EOL;
+        });
+    };
+}
+
+function asString($value): string
+{
+    if (is_array($value)) {
+        return json_encode($value);
+    }
+
+    if (is_bool($value)) {
+        return (string)(integer)$value;
+    }
+
+    return (string)$value;
+}
+
+/**
+ * Partial Apply
+ *
+ * @param callable $func
+ * @param $lastValue
+ * @return callable
+ *
+ */
+function p(callable $func, $lastValue): callable
+{
+    return function ($value) use ($func, $lastValue) {
+        return $func($value, $lastValue);
+    };
+}