diff --git a/src/index.ts b/src/index.ts
index f2c7070..83367e9 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -93,10 +93,10 @@ function internalizeProducer<T>(producer: Producer<T> & Partial<InternalProducer
 }
 
 class StreamSub<T> implements Subscription {
-  constructor(private _stream: Stream<T>, private _listener: Listener<T>) {}
+  constructor(private _stream: Stream<T>, private _listener: InternalListener<T>) {}
 
   unsubscribe(): void {
-    this._stream.removeListener(this._listener);
+    this._stream._remove(this._listener);
   }
 }
 
@@ -1225,9 +1225,9 @@ export class Stream<T> implements InternalListener<T> {
    * @param {Listener} listener
    * @returns {Subscription}
    */
-  subscribe(listener: Listener<T>): Subscription {
+  subscribe(listener: Partial<Listener<T>>): Subscription {
     this.addListener(listener);
-    return new StreamSub<T>(this, listener);
+    return new StreamSub<T>(this, listener as InternalListener<T>);
   }
 
   /**
diff --git a/tests/stream.ts b/tests/stream.ts
index 72e3312..a755b81 100644
--- a/tests/stream.ts
+++ b/tests/stream.ts
@@ -413,5 +413,20 @@ describe('Stream', () => {
 
       done();
     });
+
+    it('should accept a partial listener', (done: any) => {
+      const stream = xs.empty();
+      const noop = (): void => void 0;
+      const listener = {
+        next: noop,
+      };
+
+      const subscription = stream.subscribe(listener);
+
+      assert.equal(typeof subscription, 'object');
+      assert.equal(typeof subscription.unsubscribe, 'function');
+
+      done();
+    });
   });
 });