Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
`h.codecCtor.Create` will return a `*service.OwnedScanner`, but `h.codec` has type `codec.DeprecatedFallbackStream`, so if we get an error from `h.codecCtor.Create`, the `h.codec != nil` check in `Connect` will be true, so Benthos will think the input is connected. This can happen if the codec specification isn't compatible with the received data. Signed-off-by: Mihai Todor <[email protected]>
- Loading branch information