Он решает проблему с повторным созданием парсера на каждое сообщение.

Question

Kotlin Community

Kirill Gamazkov

Он решает проблему с повторным созданием парсера на каждое сообщение.

Разве нет?

#kotlin #programming #russian

0

12.10.2020

11 ответов

17 просмотров

Kirill Gamazkov Автор вопроса

Vladimir Petraković
Вообще он совсем не об этом, и да, я не представля...

Ну как-то вот так: abstract class BaseMessageType {} class SomeType: BaseMessageType() {} class OtherType: BaseMessageType() {} interface UserCallbacks { fun onSomeMessage(msg: SomeType) fun onOtherMessage(msg: OtherType) } class LibraryApi(val callbacks: UserCallbacks) { fun parse(msg: Array<Byte>) { if (msg.size % 2 == 1) callbacks.onSomeMessage(SomeType()) else callbacks.onOtherMessage(OtherType()) } } fun Flow<Array<Byte>>.parse(): Flow<BaseMessageType> = callbackFlow { val callbacks = object: UserCallbacks { override fun onSomeMessage(msg: SomeType) { offer(msg) } override fun onOtherMessage(msg: OtherType) { offer(msg) } } val parser = LibraryApi(callbacks) collect { bytes -> parser.parse(bytes) } }

0

12.10.2020

Vladimir Petraković

Kirill Gamazkov
Ну как-то вот так: abstract class BaseMessageType ...

Это немного отличается от изначального интерфейса suspend fun parse(bytes): Message

0

12.10.2020

Kirill Gamazkov Автор вопроса

Vladimir Petraković
Это немного отличается от изначального интерфейса ...

Ну, я запостил задачу-минимум, а мне подсказали сразу решение задачи-максимум

0

12.10.2020

Vladimir Petraković

Kirill Gamazkov
Ну, я запостил задачу-минимум, а мне подсказали ср...

Значит, @noraltavir хорошо прокачал телепатию))

0

12.10.2020

Alexander Nozik

Vladimir Petraković
Значит, @noraltavir хорошо прокачал телепатию))

ну так. Single-fire callback - это вообще редкая штука.

0

12.10.2020

Vladimir Petraković

Alexander Nozik
ну так. Single-fire callback - это вообще редкая ш...

Да не такая уж редкая, куча таких асинхронных API с методами вида void doSomething(args, callback)

0

12.10.2020

Alexander Nozik

Vladimir Petraković
Да не такая уж редкая, куча таких асинхронных API ...

Для этого не делают интерфейс с отпиской

0

12.10.2020

Kirill Gamazkov Автор вопроса

Alexander Nozik
ну так. Single-fire callback - это вообще редкая ш...

Ну, совсем идеально было бы всё-таки flow-версию построить через single, хотя бы для юнит-тестов каких-нибудь могло пригодиться потом. В конце концов, предметка не принуждает оперировать последовательностями вместо отдельных сообщений. Это уже ограничения имплементации диктуют

0

12.10.2020

Alexander Nozik

Kirill Gamazkov
Ну, совсем идеально было бы всё-таки flow-версию п...

Никто не мешает делать single-fire flow

0

12.10.2020

Vladimir Petraković

Kirill Gamazkov
Ну, совсем идеально было бы всё-таки flow-версию п...

Это не проблема: flowOf(foo).parse().toList()

0

12.10.2020