Package-level declarations
Types
Link copied to clipboard
interface Rx2MavConnection
Functions
Link copied to clipboard
A helper function to wrap a MavConnection as an Rx2MavConnection. The returned Rx2MavConnection uses the provided scheduler to perform the IO operations of reading and sending the messages.
fun MavConnection.asRx2(scheduler: Scheduler = Schedulers.io(), onFailure: Rx2MavConnection.() -> Unit = {}): Rx2MavConnection
A helper function to wrap a MavConnection as an Rx2MavConnection. The returned Rx2MavConnection uses the provided scheduler to perform the IO operations of reading and sending the messages. The onFailure callback is invoked when an exception is thrown while reading the messages. This can be used to implement a custom reconnection strategy.