fix(fromEvent): rename static domEvent() to fromEvent() as extra

Moved it to the extra folder.

src/Stream.ts

@@ -20,7 +20,6 @@ import {
   CombineInstanceSignature,
   CombineFactorySignature,
   CombineProjectFunction} from './factory/CombineProducer';
-import {EventProducer} from './factory/EventProducer';
 import {FromArrayProducer} from './factory/FromArrayProducer';
 import {IntervalProducer} from './factory/IntervalProducer';
 import {MergeProducer} from './factory/MergeProducer';
@@ -173,12 +172,6 @@ export class Stream<T> implements InternalListener<T> {
       return new Stream<R>(new CombineProducer<R>(project, streams));
     };
 
-  static domEvent(node: EventTarget,
-                  eventType: string,
-                  useCapture: boolean = false): Stream<Event> {
-    return new Stream<Event>(new EventProducer(node, eventType, useCapture));
-  }
-
   map<U>(project: (t: T) => U): Stream<U> {
     return new Stream<U>(new MapOperator(project, this));
   }

src/factory/EventProducer.ts → src/extra/fromEvent.ts

@@ -1,7 +1,8 @@
+import {Stream} from '../Stream';
 import {InternalProducer} from '../InternalProducer';
 import {InternalListener} from '../InternalListener';
 
-export class EventProducer implements InternalProducer<Event> {
+export class DOMEventProducer implements InternalProducer<Event> {
   private listener: EventListener;
 
   constructor(private node: EventTarget,
@@ -20,3 +21,9 @@ export class EventProducer implements InternalProducer<Event> {
     node.removeEventListener(eventType, listener, useCapture);
   }
 }
+
+export default function fromEvent(node: EventTarget,
+                                  eventType: string,
+                                  useCapture: boolean = false): Stream<Event> {
+  return new Stream<Event>(new DOMEventProducer(node, eventType, useCapture));
+}

tests/factory/domEvent.ts → tests/extra/fromEvent.ts

@@ -1,4 +1,5 @@
 import xs from '../../src/index';
+import fromEvent from '../../src/extra/fromEvent';
 import {noop} from '../../src/utils/noop';
 import * as assert from 'assert';
 
@@ -36,10 +37,10 @@ class FakeEventTarget implements EventTarget {
   }
 };
 
-describe('xs.domEvent', () => {
+describe('fromEvent (extra)', () => {
   it('should call addEventListener with expected parameters', () => {
     const target = new FakeEventTarget();
-    const stream = xs.domEvent(target, 'test', true);
+    const stream = fromEvent(target, 'test', true);
 
     stream.addListener({next: noop, error: noop, complete: noop});
 
@@ -49,7 +50,7 @@ describe('xs.domEvent', () => {
 
   it('should call addEventListener with expected parameters', () => {
     const target = new FakeEventTarget();
-    const stream = xs.domEvent(target, 'test');
+    const stream = fromEvent(target, 'test');
 
     stream.addListener({next: noop, error: noop, complete: noop});
 
@@ -59,7 +60,7 @@ describe('xs.domEvent', () => {
 
   it('should propagate events', (done) => {
     const target = new FakeEventTarget();
-    const stream = xs.domEvent(target, 'test').take(3);
+    const stream = fromEvent(target, 'test').take(3);
 
     let expected = [1, 2, 3];
 
@@ -84,7 +85,7 @@ describe('xs.domEvent', () => {
 
   it('should call removeEventListener with expected parameters', (done) => {
     const target = new FakeEventTarget();
-    const stream = xs.domEvent(target, 'test', true);
+    const stream = fromEvent(target, 'test', true);
 
     stream.take(1).addListener({
       next(x) {},

tests/stream.ts

@@ -44,7 +44,6 @@ describe('Stream', () => {
     assert.equal(typeof xs.interval, 'function');
     assert.equal(typeof xs.merge, 'function');
     assert.equal(typeof xs.combine, 'function');
-    assert.equal(typeof xs.domEvent, 'function');
   });
 
   it('should have all the core operators as methods, plus addListener and removeListener', () => {