Добрый день!

Столкнулся с одной проблемой и нуждаюсь в помощи. Опишу задачу:
Я в одни reqest-e получаю объект содержащий 4 переменных типа String(email,username,displayname,data) мне нужно взять лишь email из данного объекта для использования второго reqest-a так как для него нужен Auth and email.

Как я могу это сделать?

Не понятно, что за request и в чем проблема?

“@GET”

То есть это спринг flux правильно?

Я знаю что это называться reqest использую retrofit

Добрый день!

Столкнулся с одной проблемой и нуждаюсь в помощи. Опишу задачу:
Я в одни reqest-e получаю объект содержащий 4 переменных типа String(email,username,displayname,data) мне нужно взять лишь email из данного объекта для использования второго reqest-a так как для него нужен Auth and email.

Как я могу это сделать?

Первый запрос -> получил email -> второй запрос с email

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

Сделать собственный оператор буфферинга для flow, у которого будет какая-то функция определяющая конец пакета и отправляющая накопленные данные дальше

Вот прям вот минуту назад начал его писать. Но это совсем не простая штука

Как пример реализация bufferTimeout из интернета. Вместо размера и таймаута использовать функцию предикат. Должно быть не сложно

Довольно сложно если учесть, что разделитель может быть внутри блока. Плюс надо минимизировать копирования. Ничего невозможного, конечно.

Надо проверять каждый блок на разделитель, плюс надо проверить не попал ли разделитель частью в прошлый блок, частью в следующий. Потом надо стереть уже отправленный блока и оставить хвост нового. В общем сильно сложнее, чем timeout, но doable.

Как вариант это может делать в дополнение к предикату входящая функция разделитель. На выходе она может давать список пакетов с флагом завершения проверяемые предикатом. Дальше отправлять только завершенные пакеты.

Надо проверять каждый блок на разделитель, плюс надо проверить не попал ли разделитель частью в прошлый блок, частью в следующий. Потом надо стереть уже отправленный блока и оставить хвост нового. В общем сильно сложнее, чем timeout, но doable.

Для такого я сделал Стейт машину
Которая в соответствии со стейтом  и  расрезает на пакеты по мери поступления данных и отсылает готовые и все это по байтово бежит