corda / net.corda.node.utilities / rx.Observable

### Extensions for rx.Observable

wrapWithDatabaseTransaction | `fun <T : Any> Observable<T>.wrapWithDatabaseTransaction(db: Database? = null): Observable<T>` Wrap delivery of observations in a database transaction. Multiple subscribers will receive the observations inside the same database transaction. This also lazily subscribes to the source rx.Observable to preserve any buffering that might be in place.