Merge pull request #6 from reactphp-parallel/rename-stream-to-channel

Rename stream to channel

Author: WyriHaximus

src/Factory.php

@@ -1,6 +1,4 @@
-<?php
-
-declare(strict_types=1);
+<?php declare(strict_types=1);
 
 namespace ReactParallel\Streams;
 
@@ -18,13 +16,13 @@ public function __construct(EventLoopBridge $loop)
         $this->loop = $loop;
     }
 
-    public function stream(Channel $channel): Observable
+    public function channel(Channel $channel): Observable
     {
         return $this->loop->observe($channel);
     }
 
     public function single(Channel $channel): PromiseInterface
     {
-        return $this->loop->observe($channel)->take(1)->toPromise();
+        return $this->channel($channel)->take(1)->toPromise();
     }
 }

tests/SingleRecvObservableTest.php

@@ -47,7 +47,7 @@ public function recv(): void
 
         $promises = [];
         foreach ($channels as $channel) {
-            $promises[] = $recvObservable->stream($channel)->toArray()->toPromise();
+            $promises[] = $recvObservable->channel($channel)->toArray()->toPromise();
         }
 
         $rd = $this->await(all($promises), $loop, 3.3);