How can I correctly use "MqttSink" in multithreading？

[Merely-chao]

We are using Rc here, not Arc. Do we need to wrap an outer layer of Arc? I think this is a bit strange

[fafhrd91]

you need two part:

1. start task in same thread as sink, read from channel in a loop and send data to sink
2. send other part of channel to different thread and use it to send data to mqtt sink.

PS ntex in general designed to be used in single threaded environment