Relight script example

relight_script_example.cpp

Var<Stream> stream(new Stream(poller));
poller->run([=](std::function<void(std::function<void()>)> stop) {
    std::function<void()> cleanup = [=]() {
        poller->break_loop();
        stream->close();
    };
    stream->connect_ipv4("127.0.0.1", 8080, [=]() {
        stream->on_data([=](Var<Bytes>) {
            stream->on_flush([=]() {
                stream->write("flushed\n");
                stream->on_data([=](Var<Bytes>) {
                    stop(cleanup);
                });
                stream->on_flush([]() {});
            });
            stream->write("received first chunk\n");
        });
        stream->on_error([=](int err) {
            stop(cleanup);
        });
    }, [=](int err) {
        stop(cleanup);
    });
});