Эх, надеялся без мютекса, поскольку Recipient умеет Clone и я его только создам и буду иногда читать. А тут на тебе, ругается на static Foo: OnceCell<Recipient<FooMessage>> = OnceCell::new(); поскольку Recipient не умеет Sync

Простите, а в чем проблема-то? У вас же при создании в мейне актора вы делаете .start() что дает вам Addr<YourActor>, и потом этот адрес можно в .data(addr.clone()) покласть, и он будет доступен во всех слушателях как Data<Addr<YourActor>>

На самом деле, впервые слышу. Сейчас почитаю доки по этому поводу. Спасибо однако

Ну у actix-web есть example и там есть экземпл с чатом, и там как раз есть такой случай))

Вот https://github.com/actix/examples/blob/master/websocket-chat/src/main.rs

А вот эти мутексы ванцелы тут нафик не нужны)

Как в функцию ожидающую impl futures::sink::Sink<T> впихнуть tokio::sync::mpsc::Sender<T> ?

> I believe Sink was removed with v0.2 as the trait does not have a clear path into the standard library.

source: https://github.com/tokio-rs/tokio/issues/2389

Кажется можно накостылить что-то типа
futures::sink::drain().with(|msg| async {sender.send(msg).await})

Я уже каналы из futures взял

once_cell

Уже знакомлюсь с actix_web::web::Data вместо использования глобальной переменной. Между прочем, почему все так once_cell рекомендуют? Это стильно, модно, молодёжно и должно в будущем заменить lazy_static?

нет, просто это логичнее и больше вариантов для маневров в безопасном виде, просто прочти документацию, а лучше код глянь

Ну от нафига эта штука человеку в axctix-web, если там есть нативные способы это вот все делать?)

Какие? о.О

Не подскажете как в tokio комбинировать свои реализации Encoder/Decoder с LengthDelimitedCodec?

1) Нужно создавать свою структуру с LengthDelimitedCodec и делать что типа

struct MyCodec {
   frame_codec: LengthDelimitedCodec,
}

// MyCodec Encoder.encode
fn encode(&mut self, item: Self::Item, dst: &mut BytesMut)  {
   // Сначала преобразуем Item в bytes.
   // Передаем его в LengthDelimitedCodec,
   // чтобы получить длину пакета + пакет
   self.frame_codec.encode(bytes, dst)
}

// MyCodec Decoder.decode
fn decode(&mut self, src: &mut BytesMut)  {
   // Сначала результат работы LengthDelimitedCodec
   let result = self.frame_codec.decode(src);
   // Если все хорошо, то в result содержится наш пакет
   // и мы разбираем байты в Item
}

Это вроде бы работает