awaitRequestFragments

fun awaitRequestFragments(topic: String = gtwTopic, key: ByteString, message: ProtoMessageWrapper, timeoutMs: Long = DEFALT_AWAIT_TIMEOUT_FRAGMENTS): List<ProtoMessageWrapper>

Отправить запрос и собрать все пакеты-ответы в список. Работает с ProtoErrorCode.FRAGMENTED_* и собирает пакеты пока не придёт последний с FRAGMENTED_END.

Return

Список полученных ProtoMessageWrapper в порядке получения

Parameters

topic

Топик назначения (по умолчанию шлюз)

key

Ключ сообщения

message

Сам запрос

timeoutMs

Общее время ожидания на все фрагменты (мс)

Throws

если запрос с таким ключом уже есть в очереди