More complex example and small fix for Http

composer.json

@@ -43,6 +43,7 @@
     "ext-swoole": "*"
   },
   "require-dev": {
-    "phpunit/phpunit": "^6.0"
+    "phpunit/phpunit": "^6.0",
+    "rx/operator-extras": "^2.1"
   }
 }

examples/read_and_http.php

@@ -0,0 +1,19 @@
+<?php
+
+require_once __DIR__ . '/../vendor/autoload.php';
+
+$file = \Rx\Swoole\Async::read(__DIR__ . '/url_list.txt');
+
+$urlInfo = $file
+    ->cut("\n")
+    ->flatMap(function ($url) {
+        return \Rx\Swoole\Http::get($url)
+            ->map(function ($content) use ($url) {
+                return $url . " is " . strlen($content) . " bytes.\n";
+            });
+    });
+
+$urlInfo->subscribe(function ($info) {
+        echo $info;
+    });
+

examples/url_list.txt

@@ -0,0 +1,3 @@
+https://www.google.com:80/
+https://www.facebook.com:80/
+https://www.microsoft.com:80/

src/Http.php

@@ -69,8 +69,8 @@ public static function head(string $url, array $headers = []): Observable
     private static function createClient($url)
     {
         $urlParts = parse_url($url);
-        $secure   = 'wss' === substr($url, 0, 3);
-        $port     = $urlParts['port'] ?: ($secure ? 443 : 80);
+        $secure   = 'https' === substr($url, 0, 3);
+        $port     = $urlParts['port'] ?? ($secure ? 443 : 80);
 
         $cli = new \Swoole\Http\Client($urlParts['host'], $port);