message: fix format and filter
diff: -import * as Array_ from "../../Array"
  +import * as A from "../../Array"
  import type { Predicate } from "../../Function"
  import { pipe } from "../../Function"
  import type { Stream } from "./definitions"
  @@ -8,10 +8,17 @@ import { mapChunks } from "./mapChunks"
  * Applies the predicate to each element and allows passing elements
  * to reach the output of this stream.
  */
  -export const filter = <O>(f: Predicate<O>) => <R, E>(
  - self: Stream<R, E, O>
  -): Stream<R, E, O> =>
  - pipe(
  - self,
  - mapChunks((o) => Array_.chain_(o, (o) => (f(o) ? [o] : [])))
  - )
  +export function filter<O>(f: Predicate<O>) {
  + return <R, E>(self: Stream<R, E, O>): Stream<R, E, O> => filter_(self, f)
  +}
  +
  +/**
  + * Applies the predicate to each element and allows passing elements
  + * to reach the output of this stream.
  + */
  +export function filter_<R, E, O>(
  + self: Stream<R, E, O>,
  + f: Predicate<O>
  +): Stream<R, E, O> {
  + return pipe(self, mapChunks(A.filter(f)))
  +}
  