There's one in the example (streaming from multiple cloudtrail files and grepping on the resulting stream)