Reactive Stream Questions

[Douglas Surber]

Session.close submits a closeOperation. Execution of this operation is async. Try with resources works exactly as desired. The reactive stream alternative is in no way different is this regard from MAIN.

  try (Session s = ds.getSession()) {
    s.rowCountOperation(sql).submit();
  }

In this example the user thread submits three Operations without blocking, attachOperation, rowCountOperation, closeOperation. The closeOperation is likely submitted long before the attachOperation is executed, but that is just fine. CloseOperation is every bit as asynchronous as the rowCountOperation.

> On Aug 1, 2018, at 7:29 AM, Ben Hale <bhale at pivotal.io> wrote:
> 
> try/catch, because it happens within the execution flow rather than async, is problematic in an RS environment.  Instead, you need to directly execute a close at the appropriate point in the async execution.