diff --git a/src/Factory.php b/src/Factory.php
index 7e1f2c3..3a2c597 100644
--- a/src/Factory.php
+++ b/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();
     }
 }
diff --git a/tests/SingleRecvObservableTest.php b/tests/SingleRecvObservableTest.php
index df12412..bca090b 100644
--- a/tests/SingleRecvObservableTest.php
+++ b/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);