Option<channel> норм

https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=b1f19d1e80cbed07356616752058f6e7 у меня не вышло что-то

Ну и на самом деле я понял, что это всё не очень правильно. У oneshot::channel и mpsc::unbounded не зря такой дизайн. В одну структуру засунуть их засунешь, а через async boundary протащить не выйдет.

а зачем в одну структуру оба конца класть?

я думал ты хочешь только ресивер положить в опшин

(ну или в стрим)

Ну голова так работает :) Хочется всё абстрагировать, чтобы не думать о кишках. Но пока не выходит.

ну в скриптовом языке у тебя это было бы так потому что Rc/Gc не виден. А в расте тогда - Rc::new() и два конца будут все равно, только в виде двух смартпоинтеров на структуру с обоими концами

короче, проще сделать отдельно сендер и ресивер. Сендер передать тому, кто сигналит, а ресивер читать в своем select! блоке

угу, тут по-другому дизайнить надо как-то. Пока еще думаю, как. Придумаю – расскажу

Или спрошу :)

это не те кишки, о которых стоит волноваться =)

Товарищи, хочу имплементировать свой трейт Arg для простых типов вроде u8 u32 и тд
также хочу имплементировать его для все типов которые имплементируют трейт protobuf::Message
получается

pub trait Arg { ... }
impl Arg for bool { ... }
impl<T> Arg for T where T: protobuf::Message { ... }

получаю ошибку

conflicting implementation for bool
note: upstream crates may add a new impl of trait protobuf::core::Message for type bool in future versions

Подскажите пожалуйста как это разрулить и откуда она вообще берется..

См. "orphan rule". Ты не можешь иметь две потенциально конфликтующие реализации трейта на один и тот же тип. В твоем случае второй импл имеет трейт баунд на внешний трейт. Если б он был объявлен в твоем же крейте, то ты бы мог так написать и компилятор проверил бы что у тебя нет impl protobuf::Message for bool (из-за конфликтов). А поскольку протобуф - из другого крейта, то кто-то там может объявить impl protobuf::Message for bool и тогда будет конфликт с твоей либой.

в твоем случае фикс такой: сделай тип-обертку вокруг protobuf::Message и объяви Arg для него. Тогда компилятор увидит что этот тип не пересекается с bool/u8/u16 и все ок

типа struct<M: protobuf::Message> ProtoMsg(M). Перед парсингом - упаковываешь, после парсинга - вынимаешь через .0

☝️

Понял, Спасибо больше! буду разбираться)

pub trait Arg { ... }
impl Arg for bool { ... }
impl<T> Arg for ProtoMsg<T> where T: protobuf::Message { ... }