pub fn parse_stream_source(input: &str) -> IResult<&str, StreamSource>
Parse: from stream(“stream-name”)
from stream("user-events") from stream("sensor-readings")