Code very similar to the example does not work about message-io HOT 6 CLOSED

let (network_handler, network_listener) = message_io::node::split();
let (server, _) = network_handler.network().connect(message_io::network::Transport::FramedTcp, SERVER_ADDRESS).unwrap();

let mut network_thread = network_listener.for_each_async(move |node_event| match node_event {
    message_io::node::NodeEvent::Network(net_event) => match net_event {
        message_io::network::NetEvent::Connected(_, is_ok) => {
            assert!(is_ok);

        },
        message_io::network::NetEvent::Message(_, data) => {

        },
        message_io::network::NetEvent::Disconnected(_) => {},
        message_io::network::NetEvent::Accepted(_, _) => unreachable!()
    },
    message_io::node::NodeEvent::Signal(_) => {}
});

error[E0283]: type annotations needed for `NodeEvent<'_, S>`
   --> src/client.rs:29:72
    |
26  | ...work_listener) = message_io::node::split();
    |                     ------------------------- type must be known at this point
...
29  | ...network_listener.for_each_async(move |node_event| match node_event {
    |                                          ^^^^^^^^^^
    |
    = note: cannot satisfy `_: Send`
note: required by a bound in `message_io::node::split`
   --> /home/wojtek/.cargo/registry/src/index.crates.io-6f17d22bba15001f/message-io-0.18.1/src/node.rs:180:17
    |
180 | pub fn split<S: Send>() -> (NodeHandler<S>, NodeListener<S>) {
    |                 ^^^^ required by this bound in `split`
help: consider giving this closure parameter an explicit type, where the type for type parameter `S` is specified
    |
29  |         let mut network_thread = network_listener.for_each_async(move |node_event: NodeEvent<'_, S>| match node_event {
    |                                                                                  ++++++++++++++++++