public Mono < Void > onClose ( Disposable disposable ) { return Mono . create ( sink -> inbound . withConnection ( connection -> connection . onDispose ( disposable ) . onTerminate ( ) . subscribe ( sink :: success , sink :: error , sink :: success ) ) ) ; }
Lambda setter for reacting on channel close occurrence .