Function onInput

packages/platform/src/Ndjson.ts:160–163

(input: Chunk.Chunk<string>)

    never
  > = Channel.readWithCause({
    onInput(input: Chunk.Chunk<string>) {
      const filtered = filterEmpty(input)
      return Channel.zipRight(Chunk.isEmpty(filtered) ? Channel.void : Channel.write(filtered), loop)
    },
    onFailure(cause: Cause.Cause<IE>) {
      return Channel.failCause(cause)
    },