Streaming implementation