Function parse

flow-rs/src/loader/python/port.rs:82–102

(s: &str)

}

pub(super) fn parse<T>(s: &str) -> (String, AnyPort<std::sync::Arc<T>>) {
    let mut ss = s.split(':');
    let name = ss.next().unwrap();
    ss.next()
        .map(|x| {
            if x == "[]" {
                (
                    format!("[{}]", name),
                    AnyPort::new(name.to_owned(), PortTy::List),
                )
            } else if x == "{}" {
                (
                    format!("{{{}}}", name),
                    AnyPort::new(name.to_owned(), PortTy::Dict),
                )
            } else {
                unreachable!("unexpected port type {}", x)
            }
        })
        .unwrap_or_else(|| (name.to_owned(), AnyPort::new(name.to_owned(), PortTy::Unit)))
}

pub(super) fn port_name(s: &str) -> String {
    let mut ss = s.split(':');