corda/client
Konstantinos Chalkias d72b75caa4 Observable.subscribe().unsubscribe() and ListenableFuture.cancel() (#397)
Observable.subscribe().unsubscribe() dance to free up the MQ resources server-side.

* remove an unused import

* implement a FlowHandle<Transaction>.finalize method

* Rename finalize() to discard() - remove the collection and run discard individually

* Remove unused imports

* Observable.notUsed helper function

* Tweaks to comments

* FlowHandle implements AutoClosable

* Resolving conflicts and move notUsed to RPC module

* Copy Observable.notUsed in core module.

* delete discard method
2017-03-31 10:08:12 +01:00
..
jackson Replace kotlinx-support-jdk8 with kotlin-stdlib-jre8. (#463) 2017-03-30 16:27:01 +01:00
jfx Tactical fix for Explorer crash issue under Kotlin 1.1.1. Original code compiles, but then throws a typecast expression at runtime when trying to process the lambdas. 2017-03-30 17:44:23 +01:00
mock Replace unused variables with _ after kotlin 1.1.1 upgrade (#456) 2017-03-29 13:54:40 +01:00
rpc Observable.subscribe().unsubscribe() and ListenableFuture.cancel() (#397) 2017-03-31 10:08:12 +01:00