rename state parameter for statefulFilter

srijs · May 20, 2016 · 97f540c · 97f540c
1 parent 630cb7a
commit 97f540c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/compat/output.ts b/src/compat/output.ts
@@ -43,7 +43,7 @@ export class IntoOutputStreamState {
   }
 }
 
-export function intoOutputStream<F>(output: () => NodeJS.WritableStream): Sink<Buffer, IntoOutputStreamState, void> {
+export function intoOutputStream(output: () => NodeJS.WritableStream): Sink<Buffer, IntoOutputStreamState, void> {
   return new Sink<Buffer, IntoOutputStreamState, void>({
     onStart: () => Promise.resolve(new IntoOutputStreamState(output())),
     onData: (state, buf) => state.write(buf),

diff --git a/src/source.ts b/src/source.ts
@@ -89,9 +89,9 @@ export class Source<Output> {
     return this.statefulFilter(null, (state, output) => [state, pred(output)]);
   }
 
-  statefulFilter<S>(init: S, pred: (state: S, output: Output) => [S, boolean]): Source<Output> {
-    return new Source(<State, Result>(sink: SinkInterface<Output, State, Result>) => {
-      return this.pipe<[S, State], Result>({
+  statefulFilter<State>(init: State, pred: (state: State, output: Output) => [State, boolean]): Source<Output> {
+    return new Source(<SinkState, Result>(sink: SinkInterface<Output, SinkState, Result>) => {
+      return this.pipe<[State, SinkState], Result>({
         onStart: () => sink.onStart().then(state => [init, state]),
         onData: (state, output) => {
           const res = pred(state[0], output);