RC
Так и не должен, ты ведь onNext повесил при сабскрайбе
Size: a a a
2021 May 26
AI
When this BehaviorSubject is terminated via onError(Throwable) or onComplete(), the last observed item (if any) is cleared and late Observers only receive the respective terminal event.
v
Вот теперь понятно. Спасибо. эрыкс как всегда подкинет сюрпризов...
2021 May 27
A
Господа а как можно компактно заапдейтить BehaviorSubject и затем запустить функцию с новым айтемом?
A
Т.е. у меня есть функция где я подписываюсь и делаю subject.onNext(item), поможет ли здесь doOnSuccess?
2021 June 01
OP
Доброго! Как можно объединить это?
2021 June 03
c
Всем привет, хочу сделать так, что бы rxJava могла читать и писать в переменную класса. И что бы это было потокобезопасно
c
'''private var strings = listOf<String>()
override fun getStrings(): Single<List<String>> {
return Single.just(contacts)
.flatMap {
if (it.isEmpty()) {
model.getStrings()
} else {
Single.just(it)
}
}
.doOnSuccess {
strings = it
}
}'''
override fun getStrings(): Single<List<String>> {
return Single.just(contacts)
.flatMap {
if (it.isEmpty()) {
model.getStrings()
} else {
Single.just(it)
}
}
.doOnSuccess {
strings = it
}
}'''
sm
strings = if (contacts.isEmpty()) model.getStrings() else contacts
return Single.just(strings)
return Single.just(strings)
c
model.getStrings возвращает single
2021 June 04
A
1) как на счёт того, чтобы использовать не single со списком элементов, а обрабатывать данные контакты через стриминг flowable/observable? Или contacts тут не список?
1) вы меняете strings в doOnSuccess, предлагаю использовать атомики (https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicReference.html), либо обернуть изменение этой переменной в блокировку, что является менее приятным решением.
1) вы меняете strings в doOnSuccess, предлагаю использовать атомики (https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicReference.html), либо обернуть изменение этой переменной в блокировку, что является менее приятным решением.
A
Если, допустим, необходимо расспаралелить и в конце подождать результат, то у Flowable можно zip выполнить и потом спокойно посетить атомик переменную.
2021 June 09
А
Всем привет. как остановить цикл foreach который отрабатывает в другом потоке?
A
Завязываться на какое-то условие. И в случае выполнен оного делать break.
S'
Приветствую.
В C# у меня есть вот такой ивент:
В C# у меня есть вот такой ивент:
public event Func<SocketInteraction, Task> InteractionCreated, хочу преобразовать его в IObservable. Вызываю:Observable.FromEvent<Func<SocketInteraction, Task>, SocketInteraction>(и при попытке привязаться к нему получаю
action => InteractionCreated += action,
action => InteractionCreated -= action
);
System.ArgumentException: Cannot bind to the target method because its signature is not compatible with that of the delegate type.
Что я делаю не так?2021 June 10
А
Спасибо
2021 June 11
I
Всем привет.
Почему в логе вижу RxComputationThreadPool, а не RxSingleThread ?
Почему в логе вижу RxComputationThreadPool, а не RxSingleThread ?
repository.getItems()
.debounce(2, TimeUnit.SECONDS)
.map { it.toSet() }
.map { Log.d("TAG", Thread.currentThread().name) }
.distinctUntilChanged()
.subscribeOn(Schedulers.single())
l
наверное дебаунс на своем шедулере. посмотри в описании
AI
debounce по дефолту на Schedullers.computation() работает, соответственно, все значения там и эммитит. Там есть переопределенный debounce метод, где последним параметром шедуллер задается
AI
а если вопрос про subscribeOn, то он только на getItems действует