(cause: Cause.Cause<IE>)
| 162 | return Channel.zipRight(Chunk.isEmpty(filtered) ? Channel.void : Channel.write(filtered), loop) |
| 163 | }, |
| 164 | onFailure(cause: Cause.Cause<IE>) { |
| 165 | return Channel.failCause(cause) |
| 166 | }, |
| 167 | onDone(done: Done) { |
| 168 | return Channel.succeed(done) |
| 169 | } |