Size: a a a

ReactiveX - русскоговорящее сообщество

2020 May 08

AE

Alexandr Ermolenko in ReactiveX - русскоговорящее сообщество
источник

Еx

Ержан xD in ReactiveX - русскоговорящее сообщество
Продам спамер-рассыльщик по Телеграму.
Связь в @se_nator

https://youtu.be/ILWEf7SWEJI
источник
2020 May 09

S

Singular in ReactiveX - русскоговорящее сообщество
В чем разница между Observable.timer и ObservableTimer ?
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Кроме того что один из них Класс, другой метод класса
источник

Т

Тони in ReactiveX - русскоговорящее сообщество
Singular
Кроме того что один из них Класс, другой метод класса
А под капотом не смотрел в сравнении?
источник

S

Singular in ReactiveX - русскоговорящее сообщество
Спасибо уже разобрался, просто вернулся rx2
источник
2020 May 15

K

Kotor in ReactiveX - русскоговорящее сообщество
Ребят дайте пожалуйста решение для websocket по RxJava (Андроид).
С сокетами никогда не работал, фичу надо запилить к завтрашнему вечеру.
Нужно стримить стоки с биржи
источник

Т

Тони in ReactiveX - русскоговорящее сообщество
Kotor
Ребят дайте пожалуйста решение для websocket по RxJava (Андроид).
С сокетами никогда не работал, фичу надо запилить к завтрашнему вечеру.
Нужно стримить стоки с биржи
источник
2020 May 16

AD

Aleksey D. in ReactiveX - русскоговорящее сообщество
источник

K

Kotor in ReactiveX - русскоговорящее сообщество
👍👍👍
источник

NG

Nikita Gusarov in ReactiveX - русскоговорящее сообщество
Боже, они все никак не зарелизятся
источник
2020 May 18

LC

Lungu Cristian in ReactiveX - русскоговорящее сообщество
Какую функцию можно использовать в BehaviorSubject чтобы на onNext запускала Maybe и дальше в цепочке получать результат обеих. При этом если Maybe вернёт ошибку то цепочка не отменится ?
источник

LC

Lungu Cristian in ReactiveX - русскоговорящее сообщество
            .switchMap { city ->
               repository.getCityServices(city.cityId)
                   .map { response -> response.content to city }
                   .doOnError(this::evaluateError)
                   .onErrorResumeNext { _: Throwable -> Maybe.empty() }
                   .toObservable()
           }

Пытался вернуть EMPTY если ошибка но всёравно цепочка заканчивается
источник

EC

Evgeny Cherkasov in ReactiveX - русскоговорящее сообщество
Всем привет.
Почему может такой эксепшн происходить? java.lang.IllegalStateException: more items arrived than were requested
источник

DC

Denis Chuvasov in ReactiveX - русскоговорящее сообщество
Потому что пришло больше элементов, чем запросили.
источник

EC

Evgeny Cherkasov in ReactiveX - русскоговорящее сообщество
Перевести сообщение я могу. Что с этим делать?
источник

DC

Denis Chuvasov in ReactiveX - русскоговорящее сообщество
скорее всего копать в сторону backpressure
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Evgeny Cherkasov
Всем привет.
Почему может такой эксепшн происходить? java.lang.IllegalStateException: more items arrived than were requested
что делаешь, полный стектрейс. Никто не будет гадать, где ты эту ошибку получил
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Хочешь помощи - дай больше информации
источник

i

iamthevoid in ReactiveX - русскоговорящее сообщество
Гуглить пробовал? Я по мессейджу из ошибки сразу несколько вариантов нашёл
источник