VD
kotlin правда это не умеет?
Size: a a a
2020 April 07
ch
стирание типов не не слышали
SB
а кто умеет?
AN
конкретно так почти никто не умеет
VP
а кто умеет?
C++
AN
Стирание типов тут не при чем
SB
конструктор же какой угодно может быть, плюсам на это пофиг?
VP
конструктор же какой угодно может быть, плюсам на это пофиг?
Плюсы будут ругаться в месте использования, там же шаблоны
ПГ
Думаю как это решить)
channelFlow попробуй
OS
Насчет кода, вот тестовый вариант который заработал:
fun <T> Flow<T>.timedBuffer(millis:Long):Flow<List<T>> = channelFlow {
val list = arrayListOf<T>()
launch {
collect { list.add(it) }
}
launch {
while(true) {
delay(millis)
if(list.isNotEmpty()){
send(ArrayList(list))
list.clear()
}
}
}
}
fun <T> Flow<T>.timedBuffer(millis:Long):Flow<List<T>> = channelFlow {
val list = arrayListOf<T>()
launch {
collect { list.add(it) }
}
launch {
while(true) {
delay(millis)
if(list.isNotEmpty()){
send(ArrayList(list))
list.clear()
}
}
}
}
OS
Ты прямо рядом сидишь и прогаешь))
(
а если там интерфейс будет?
OS
Я как раз с ними сделал
VP
Насчет кода, вот тестовый вариант который заработал:
fun <T> Flow<T>.timedBuffer(millis:Long):Flow<List<T>> = channelFlow {
val list = arrayListOf<T>()
launch {
collect { list.add(it) }
}
launch {
while(true) {
delay(millis)
if(list.isNotEmpty()){
send(ArrayList(list))
list.clear()
}
}
}
}
fun <T> Flow<T>.timedBuffer(millis:Long):Flow<List<T>> = channelFlow {
val list = arrayListOf<T>()
launch {
collect { list.add(it) }
}
launch {
while(true) {
delay(millis)
if(list.isNotEmpty()){
send(ArrayList(list))
list.clear()
}
}
}
}
Непотокобезопасненько
ПГ
Насчет кода, вот тестовый вариант который заработал:
fun <T> Flow<T>.timedBuffer(millis:Long):Flow<List<T>> = channelFlow {
val list = arrayListOf<T>()
launch {
collect { list.add(it) }
}
launch {
while(true) {
delay(millis)
if(list.isNotEmpty()){
send(ArrayList(list))
list.clear()
}
}
}
}
fun <T> Flow<T>.timedBuffer(millis:Long):Flow<List<T>> = channelFlow {
val list = arrayListOf<T>()
launch {
collect { list.add(it) }
}
launch {
while(true) {
delay(millis)
if(list.isNotEmpty()){
send(ArrayList(list))
list.clear()
}
}
}
}
боюсь, он никогда не закончится
OS
Я тоже так думаю, сейчас думаю как это правильно сделать
ПГ
нужно явно канал закрыть
ПГ
как вариант - использовать флаг (не забываю о потокобезопасности)
AN
да, я не учел ограничения Flow
VP
Отменять scope после collect - самое то