diff --git a/src/core.ts b/src/core.ts index ae4a771..32981a7 100644 --- a/src/core.ts +++ b/src/core.ts @@ -29,6 +29,17 @@ export interface InternalProducer { _stop: () => void; } +export interface Producer { + start: (listener: Listener) => void; + stop: () => void; +} + +export interface Listener { + next: (x: T) => void; + error: (err: any) => void; + complete: () => void; +} + export interface OutSender { out: Stream; } @@ -45,17 +56,6 @@ export interface Aggregator extends InternalProducer, OutSender { _start: (out: Stream) => void; } -export interface Producer { - start: (listener: Listener) => void; - stop: () => void; -} - -export interface Listener { - next: (x: T) => void; - error: (err: any) => void; - complete: () => void; -} - export interface Subscription { unsubscribe(): void; }