Hi, I'm converting a process from actors to streams. I've got an actor that downloads rss feeds--which I've converted to a source, but the main reason for having a parent actor was to allow processing--there are several different implementations of the processing logic depending on the specific RSS feed downloaded. In my current actors code I run a foreach that breaks if the specific item I'm looking for is found. I was wanting to try and use a kill switch, to stop anymore items flowing through the stream, but I don't think I can do this from within a graph stage. Could someone verify whether this is correct, and if it is what the best way of handling this is, given that the parsing code currently emitsa result back to an actor.result