Package-level declarations

Types

Link copied to clipboard

Functions

Link copied to clipboard
fun MavConnection.asRx3(scheduler: Scheduler = Schedulers.io()): Rx3MavConnection

A helper function to wrap a MavConnection as an Rx3MavConnection. The returned Rx3MavConnection uses the provided scheduler to perform the IO operations of reading and sending the messages.

fun MavConnection.asRx3(scheduler: Scheduler = Schedulers.io(), onFailure: Rx3MavConnection.() -> Unit = {}): Rx3MavConnection

A helper function to wrap a MavConnection as an Rx3MavConnection. The returned Rx3MavConnection 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.