169 похожих чатов

Задачка. Вот есть кусок кода. MutableSharedFlow используется как eventLoop и

все бы хорошо, но проблема в том, что при двунаправленном канале получается, что все события в том числе возвращаются отправителю. Можно ли этого как-то избежать?

11 ответов

6 просмотров
Alexander-Nozik Автор вопроса

Пока ограничился тем, что просто вставил там фильтр (спасибо @why_oleg за то, что учел в API результат дискуссий и добавили initPayload).

Alexander Nozik
Пока ограничился тем, что просто вставил там фильт...

не только я принимал решение, но да, без этого очень сложно из котлина юзать requestChannel 🙁

Alexander-Nozik Автор вопроса
Oleg Yukhnevich
не только я принимал решение, но да, без этого оче...

Потому, что сложно отщепить один элемент?

Oleg Yukhnevich
угу

все решения выглядят не очень котлин-way, либо через канал, что тоже не очень котлин-way

Alexander-Nozik Автор вопроса
Oleg Yukhnevich
все решения выглядят не очень котлин-way, либо чер...

Не, там не сложно на самом деле, делается специальный объект типа flow с дополительным suspend fun first(), но не сказал бы, что это красиво

Alexander Nozik
Не, там не сложно на самом деле, делается специаль...

да, проблемы написать это нет, проблема в том, что выглядит не очень

о, сериализация я в процессе написания обёртки для rSocket и спользованием kotlinx.serialization что бы код, что вот там, выглядит был примерно вот так: ``` requestStream(MagixMessageFilter.serializer(), genericMessageSerializer) { filter -> magixFlow.filter(filter) } fireAndForget(genericMessageSerializer) { message -> magixFlow.emit(message) } // bi-directional connection requestChannel(genericMessageSerializer, genericMessageSerializer) { input -> input.onEach { magixFlow.emit(it) }.launchIn(this@magixAcceptor) magixFlow } ``` stay tuned 🙂 как будет что-то рабочее где-то в ветке, могу написать

Alexander-Nozik Автор вопроса
Oleg Yukhnevich
о, сериализация я в процессе написания обёртки для...

Ага, это здорово. Хотя не критично, потому что это ровно одно место, и там можно и руками прописать.

Alexander Nozik
Ага, это здорово. Хотя не критично, потому что это...

понимаю там конечно чуть по больше всего будет (и сервер, и клиент) так что если сервер/клиент строится по верх рсокет с роутингом там, или ещё чем, то будет приятнее делать это

Похожие вопросы

Обсуждают сегодня

Anyone here suffers from unexplained aural migraines, who would be up for talking for a bit? Doesn't *have* to be aural, but I am not asking about headaches, I mean actual mi...
Martin Rys
55
Вопрос по WIN32: Насколько я понимаю то все функции win32 привязаны к объектам операционной системы. Например консоль, файл, кисть, окна итд. Следовательно функции win32 упра...
Tommy Vercetti
6
подскажите пожалуйста, как мне освободить результат записанный в переменную result? в чем проблема подскажите если МОЖЕТЕ?
Михаил Helper
28
кто-то пользуется компонентами rx ? как их лучше ставить, через OPM? (lazarus)
Iluha Companets
15
Hello, can I install macOS and run flutter on a virtual machine? Is it possible to print for iphone?
Mazones
11
Дороу! У кого-нибудь есть в загашнике проверенная функция экранирования, аналог re.escape в Python? Из доки: » Escape all the characters in pattern except ASCII letters and n...
Daniil Smolyakov
9
В смысле более затратная? Общая стоимость владения лошадью меньше, чем автомобиля. В среднем.
Sergej R
10
есть тут кто-то , кто только начал изучать си? если проходите курс на степике или как-то сами изучаете, пишите, может, скооперируемся?..
Eule
25
я не магистр хаскеля, но разве не может лейзи тип конвертнуться в не-лейзи запросив вычисление содержимого прям при инициализации?
deadgnom32 λ madao
100
Скажите, тут нет проблемы? IMyInterface1 = interface function GetInterface2: IInterface2; ... function TMyInterface.GetInterface2: IInterface2; begin Result := TI...
Ruslan aka DUDE
18
Карта сайта