diff --git a/io/local/reader.go b/io/local/reader.go index 4e904bc9..d4fe3d00 100644 --- a/io/local/reader.go +++ b/io/local/reader.go @@ -117,7 +117,9 @@ func (r *Reader) StreamFiles( errorsCh <- err return } + r.streamDirectory(ctx, readersCh, errorsCh) + return }