I got a piece of code which is largely synchronous code running in different threads.
communication is mostly being done via std::sync::mpsc::channel, but now i need to have some other code passing messages to elasticsearch, which only seems to provide an async interface.