v
что делать?
Size: a a a
2021 February 23
v
Есть тут кто живой, или все уже на флоу да корутинах, а тут просто наблюдают за муками тех, кто ещё не слез с ырыкса?)
v
Лол, только сейчас прочитал чат вверху)
v
А есть какие адаптеры с корутин на ырыкс и назад, чтобы постепенно переходить? Если есть, то нормально ли работают?
AM
AM
А вот так следующий concatMap не ждёт выполнения этого
AM
Тип из 2 абзаца выходит что ты подписался, а второй горячий поток, и данные не успевают прийти
2021 February 24
v
Вроде, элементарную вещь хочу сделать, а е*усь вторые сутки.
Я хочу просто сделать фромИтерабл, сделать запрос с каждым из элементов, проигнорировав ошибки и потом собрать ответы обратно в лист.
Я хочу просто сделать фромИтерабл, сделать запрос с каждым из элементов, проигнорировав ошибки и потом собрать ответы обратно в лист.
2021 February 25
А
Всем привет! Есть наивный вопрос по Reactor
вот такой простой код:
имеем результат
one@ex.com--->Thread[parallel-1,5,main]
two@ex.com--->Thread[parallel-2,5,main]
three@ex.com--->Thread[parallel-3,5,main]
теперь вопрос - почему если закоммитить строку // .subscribeOn(
вот такой простой код:
dataPackage.setData(List.of("one@ex.com", "two@ex.com", "three@ex.com"));
Flux.fromIterable(dataPackage.getData())
.flatMap(i -> Mono.just(i)
.delaySubscription(Duration.ofMillis(2000))
.map(n -> {
System.out.println(n+ "--->" + Thread.currentThread());
return new User("111", n);
})
.subscribeOn(Schedulers.parallel())
)
.subscribe(i -> System.out.println(i));имеем результат
one@ex.com--->Thread[parallel-1,5,main]
two@ex.com--->Thread[parallel-2,5,main]
three@ex.com--->Thread[parallel-3,5,main]
теперь вопрос - почему если закоммитить строку // .subscribeOn(
Schedulers.parallel()) НИЧЕГО не поменяется в выводе?l
Александр
Всем привет! Есть наивный вопрос по Reactor
вот такой простой код:
имеем результат
one@ex.com--->Thread[parallel-1,5,main]
two@ex.com--->Thread[parallel-2,5,main]
three@ex.com--->Thread[parallel-3,5,main]
теперь вопрос - почему если закоммитить строку // .subscribeOn(
вот такой простой код:
dataPackage.setData(List.of("one@ex.com", "two@ex.com", "three@ex.com"));
Flux.fromIterable(dataPackage.getData())
.flatMap(i -> Mono.just(i)
.delaySubscription(Duration.ofMillis(2000))
.map(n -> {
System.out.println(n+ "--->" + Thread.currentThread());
return new User("111", n);
})
.subscribeOn(Schedulers.parallel())
)
.subscribe(i -> System.out.println(i));имеем результат
one@ex.com--->Thread[parallel-1,5,main]
two@ex.com--->Thread[parallel-2,5,main]
three@ex.com--->Thread[parallel-3,5,main]
теперь вопрос - почему если закоммитить строку // .subscribeOn(
Schedulers.parallel()) НИЧЕГО не поменяется в выводе?delaySubscription уже на шедулере. то есть subscribeOn не работаетА
delaySubscription уже на шедулере. то есть subscribeOn не работаетспасибо большое, действительно если закомментить delaySubscription то разница видна, потоки разные при subscribeOn и одинаковые если закомментировать
v
А мне поможет кто-нибудь?( Ну пожалуйста...
AM
А что нужно?
AM
Скинь фул задачу, и ну попытка не пытка
AM
🌝
v
Artem Mi
А что нужно?
Если упростить, хочу узнать, как мне сделать вот так вот
v
Приходит еррор, а хотелось бы, чтобы приходил лист, а ероры скипались. Проблема в том, что даже если сделать что-то типа
delayError или onErrorResumeNext(Observable.empty()), то всё равно приходит онКомплит и срабатывает туЛист, в который приходят айтемы до первой ошибки.v
Может, подойдёт способ как-то скипнуть терминальные ивенты до момента, пока я сам не решу, когда его кинуть.
И
а что мешает вообще сделать filter - и будет приходить только то что нужно, и не очень понятно зачем делать toList а потом опять toObservable ? что мешает сделать reduce
И
filter{value-> value!=2}