Method new

flow-plugins/src/bytes_server.rs:78–88

(_: String, args: &Table)

impl BytesServer {
    fn new(_: String, args: &Table) -> BytesServer {
        let _ = args.get("response").map(|resp| resp.as_str()).flatten();
        BytesServer {
            port: args["port"]
                .as_integer()
                .expect("expect args[port] in node[BytesServer]")
                .to_owned() as u16,
            inp: Default::default(),
            out: Default::default(),
        }
    }

    async fn initialize(&mut self, _: ResourceCollection) {}
    async fn finalize(&mut self) {}