python (12.9k questions)

javascript (9.2k questions)

reactjs (4.7k questions)

java (4.2k questions)

java (4.2k questions)

c# (3.5k questions)

c# (3.5k questions)

html (3.3k questions)

Questions - rx-android

How to manage error for each item when insert list of data to room with rxjava

@Dao interface NoteDao { @Insert(onConflict = OnConflictStrategy.ABORT) fun insert(note: Note):Completable @Insert(onConflict = OnConflictStrategy.ABORT) fun insert(notes: List<N...
test-img

morteza moradi

android

android-room

rx-android

Votes: 0

Answers: 1

Latest Answer

It is not really possible to understand it with your current implementation. If there is an error with the insert process you would get the onError call and there you can query your table and compare ...
test-img

Tartar

rxjava chain observalbes dynamiclly

I have a chained observable that I created like this: Disposable disposable = currentUsedAdapter.connect(ip) .observeOn(AndroidSchedulers.mainThread()) .concatMap(fallbackAdapter(Proto...
test-img

StackerSapper

java

android

rx-java

rx-java2

rx-android

Votes: 0

Answers: 1

Latest Answer

If it helps anyone... I didn't find an rxjava way to solve it so I solved in an on old java fashion way... I have created a builder class and added an observable to my main observable and at the end I...
test-img

StackerSapper

Sending data over the air and after completion end the operation using RxAndroidBLE

I am trying to send the 128 bytes of the block to BLE Controller using the RxAndroidBle library. the flow to send data from mobile to BLE controller is as follows Connect with BLE Controller Start OT...
test-img

Hunt

android

rx-java

rx-java2

rx-android

rxandroidble

Votes: 0

Answers: 1

Latest Answer

You can use flatMapIterable() with toList(). Try to add toList() operator before OTA_DATA_END command like: .toList() // wait for all commands to complete .flatMap(bytes -> mRxBleConnection.writeCh...
test-img

Akaki Kapanadze

Posts

Questions

Blogs

Jobs