@Test public void testSubscriptionExecutionResult() { ExecutionObserver observer = new ExecutionObserver() { @Override public void onResult(ExecutionResult executionResult) { assertEquals(ExecutionResult.ResultType.Subscription, executionResult.getResultType()); assertNotNull(executionResult.getSubscription()); } }; PostProcessingInterceptorWrapper ppiw = new PostProcessingInterceptorWrapper(observer, Collections.<ExecutionPostProcessor>emptyList(), ctx, key, new Object[] {}); ppiw.onResult(new ExecutionResult(subscription)); }
@Override public void onResult(ExecutionResult executionResult) { InterceptorResult state = invokePostProcessors(executionResult); if (InterceptorState.FORCE_ON_RESULT.equals(state.getState())) { observer.onResult(new ExecutionResult(state.getResult())); } else if (InterceptorState.FORCE_ON_EXCEPTION.equals(state.getState())) { forceOnException(state); } else { observer.onResult(executionResult); } }
PostProcessingInterceptorWrapper implements ExecutionObserver { @Override public void onResult(ExecutionResult executionResult) { InterceptorResult state = invokePostProcessors(executionResult); if (InterceptorState.FORCE_ON_RESULT.equals(state.getState())) { observer.onResult(new ExecutionResult(state.getResult())); } else if (InterceptorState.FORCE_ON_EXCEPTION.equals(state.getState())) { forceOnException(state); } else { observer.onResult(executionResult); } } }
PostProcessingInterceptorWrapper implements ExecutionObserver { @Override public void onResult(ExecutionResult executionResult) { InterceptorResult state = invokePostProcessors(executionResult); if (InterceptorState.FORCE_ON_RESULT.equals(state.getState())) { observer.onResult(new ExecutionResult(state.getResult())); } else if (InterceptorState.FORCE_ON_EXCEPTION.equals(state.getState())) { forceOnException(state); } else { observer.onResult(executionResult); } } PostProcessingInterceptorWrapper(	ExecutionObserver observer,
									List<ExecutionPostProcessor> postProcessors,
									final ExecutionContext ctx,
									final OperationKey key,
									final Object [] args); }
PostProcessingInterceptorWrapper implements ExecutionObserver { @Override public void onResult(ExecutionResult executionResult) { InterceptorResult state = invokePostProcessors(executionResult); if (InterceptorState.FORCE_ON_RESULT.equals(state.getState())) { observer.onResult(new ExecutionResult(state.getResult())); } else if (InterceptorState.FORCE_ON_EXCEPTION.equals(state.getState())) { forceOnException(state); } else { observer.onResult(executionResult); } } PostProcessingInterceptorWrapper(	ExecutionObserver observer,
									List<ExecutionPostProcessor> postProcessors,
									final ExecutionContext ctx,
									final OperationKey key,
									final Object [] args); @Override void onResult(ExecutionResult executionResult); }
PostProcessingInterceptorWrapper implements ExecutionObserver { @Override public void onResult(ExecutionResult executionResult) { InterceptorResult state = invokePostProcessors(executionResult); if (InterceptorState.FORCE_ON_RESULT.equals(state.getState())) { observer.onResult(new ExecutionResult(state.getResult())); } else if (InterceptorState.FORCE_ON_EXCEPTION.equals(state.getState())) { forceOnException(state); } else { observer.onResult(executionResult); } } PostProcessingInterceptorWrapper(	ExecutionObserver observer,
									List<ExecutionPostProcessor> postProcessors,
									final ExecutionContext ctx,
									final OperationKey key,
									final Object [] args); @Override void onResult(ExecutionResult executionResult);  }