Как обработать нуль в списке с помощью Rxjava2? - PullRequest
Новая
       62

Как обработать нуль в списке с помощью Rxjava2?

0 голосов
/ 22 апреля 2019

У меня есть список значений, и я собираюсь напечатать каждый его элемент с помощью Rxjava2. Если есть нулевое значение, то программа выведет «пустое значение». 

val datas: MutableList<String?> = arrayListOf("123",null ,"test12", "teas")

Flowable
            .fromIterable(datas)
            .subscribe(
                object: FlowableSubscriber<String>{
                    override fun onComplete() {
                        println("on complete")
                    }

                    override fun onSubscribe(s: Subscription) {
                        println("on subscribe")
                    }

                    override fun onNext(t: String?) {
                        if(t==null){
                          println("it's empty value")
                        } else {
                          println("value: $t")
                        }
                    }

                    override fun onError(t: Throwable?) {
                        println("error")
                        t?.printStackTrace()
                    }

                }
            )


        while(true){}

И я получил исключение, как показано ниже: 

on subscribe
error
java.lang.NullPointerException: Iterator.next() returned a null value
    at io.reactivex.internal.operators.flowable.FlowableFromIterable$IteratorConditionalSubscription.fastPath(FlowableFromIterable.java:311)
    at io.reactivex.internal.operators.flowable.FlowableFromIterable$BaseRangeSubscription.request(FlowableFromIterable.java:122)
    at io.reactivex.internal.subscribers.BasicFuseableSubscriber.request(BasicFuseableSubscriber.java:153)
    at io.reactivex.internal.operators.flowable.FlowableFlatMapMaybe$FlatMapMaybeSubscriber.onSubscribe(FlowableFlatMapMaybe.java:107)
    at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onSubscribe(BasicFuseableSubscriber.java:67)
    at io.reactivex.internal.operators.flowable.FlowableFromIterable.subscribe(FlowableFromIterable.java:66)
    at io.reactivex.internal.operators.flowable.FlowableFromIterable.subscribeActual(FlowableFromIterable.java:47)
    at io.reactivex.Flowable.subscribe(Flowable.java:14827)
    at io.reactivex.internal.operators.flowable.FlowableFilter.subscribeActual(FlowableFilter.java:37)
    at io.reactivex.Flowable.subscribe(Flowable.java:14827)
    at io.reactivex.internal.operators.flowable.FlowableFlatMapMaybe.subscribeActual(FlowableFlatMapMaybe.java:54)
    at io.reactivex.Flowable.subscribe(Flowable.java:14827)
    at TestPlay.test4(TestPlay.kt:113)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:483)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.springframework.test.context.junit4.statements.RunBeforeTestExecutionCallbacks.evaluate(RunBeforeTestExecutionCallbacks.java:74)
    at org.springframework.test.context.junit4.statements.RunAfterTestExecutionCallbacks.evaluate(RunAfterTestExecutionCallbacks.java:84)
    at org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate(RunBeforeTestMethodCallbacks.java:75)
    at org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:86)
    at org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:84)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:251)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:97)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
    at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:190)
    at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
    at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
    at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:47)
    at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242)
    at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70)

Я новичок в реактивной rxjava, и мне нужен какой-то эксперт, который поможет мне справиться с этим сценарием.

У меня есть сценарий, который мне нужно проверить с базой данных, если запись не существует, тогда я должен сохранить запись. Но когда я пытаюсь разобраться с нулевым значением, я получаю исключение, как я описал выше.

Ответы [ 2 ]

1 голос
/ 22 апреля 2019

Из документации RxJava2:

RxJava 2.x больше не принимает нулевые значения, и следующее приведет к немедленному исключению NullPointerException или в качестве сигнала для нисходящего потока.

Решение: перед повторением списка, вы должны сделать нулевую проверку.

0 голосов
/ 22 апреля 2019

Как говорилось @ Toleubek ранее: RxJava не поддерживает нулевые значения, потому что они немедленно прекращают ваш поток и вызывают onError (...) в вашем подписчике.

Вы можете прочитать об этом здесь . Но наиболее часто используемое решение для работы с нулями - это простое создание некоторого класса-обертки, который будет называться Optional / Nullable (или что-то в этом роде) с обнуляемыми данными внутри. Также вы можете прочитать одну из статей о работе с нулем в RxJava на Medium.

...