(payload, meta, context)
| 195 | |
| 196 | if (flow.options['type'] === 'filter') { |
| 197 | const handler: FilterHandler = (payload, meta, context) => |
| 198 | this.executeFlow( |
| 199 | flow, |
| 200 | { payload, ...meta }, |
| 201 | { |
| 202 | accountability: context['accountability'], |
| 203 | database: context['database'], |
| 204 | getSchema: context['schema'] ? () => context['schema'] : getSchema, |
| 205 | }, |
| 206 | ); |
| 207 | |
| 208 | events.forEach((event) => emitter.onFilter(event, handler)); |
| 209 |
no test coverage detected