org.springframework.web.context.request.async.StandardServletAsyncWebRequest#org.springframework.mock.web.test.MockAsyncContext源码实例Demo

下面列出了org.springframework.web.context.request.async.StandardServletAsyncWebRequest#org.springframework.mock.web.test.MockAsyncContext 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： spring-analysis-note 文件： WebAsyncManagerErrorTests.java

@Test
public void startCallableProcessingErrorAndComplete() throws Exception {
	StubCallable callable = new StubCallable();

	CallableProcessingInterceptor interceptor = mock(CallableProcessingInterceptor.class);
	Exception e = new Exception();
	given(interceptor.handleError(this.asyncWebRequest, callable, e)).willReturn(RESULT_NONE);

	this.asyncManager.registerCallableInterceptor("interceptor", interceptor);
	this.asyncManager.startCallableProcessing(callable);

	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);
	this.asyncWebRequest.onComplete(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(e, this.asyncManager.getConcurrentResult());

	verify(interceptor).beforeConcurrentHandling(this.asyncWebRequest, callable);
	verify(interceptor).afterCompletion(this.asyncWebRequest, callable);
}

源代码2 项目： spring-analysis-note 文件： WebAsyncManagerErrorTests.java

@Test
public void startCallableProcessingErrorAndResumeThroughCallback() throws Exception {

	StubCallable callable = new StubCallable();
	WebAsyncTask<Object> webAsyncTask = new WebAsyncTask<>(callable);
	webAsyncTask.onError(new Callable<Object>() {
		@Override
		public Object call() throws Exception {
			return 7;
		}
	});

	this.asyncManager.startCallableProcessing(webAsyncTask);

	Exception e = new Exception();
	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(7, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码3 项目： spring-analysis-note 文件： WebAsyncManagerErrorTests.java

@Test
public void startCallableProcessingErrorAndResumeThroughInterceptor() throws Exception {

	StubCallable callable = new StubCallable();

	CallableProcessingInterceptor interceptor = mock(CallableProcessingInterceptor.class);
	Exception e = new Exception();
	given(interceptor.handleError(this.asyncWebRequest, callable, e)).willReturn(22);

	this.asyncManager.registerCallableInterceptor("errorInterceptor", interceptor);
	this.asyncManager.startCallableProcessing(callable);

	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(22, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());

	verify(interceptor).beforeConcurrentHandling(this.asyncWebRequest, callable);
}

源代码4 项目： spring-analysis-note 文件： WebAsyncManagerErrorTests.java

@Test
public void startCallableProcessingAfterException() throws Exception {

	StubCallable callable = new StubCallable();
	Exception exception = new Exception();

	CallableProcessingInterceptor interceptor = mock(CallableProcessingInterceptor.class);
	Exception e = new Exception();
	given(interceptor.handleError(this.asyncWebRequest, callable, e)).willThrow(exception);

	this.asyncManager.registerCallableInterceptor("errorInterceptor", interceptor);
	this.asyncManager.startCallableProcessing(callable);

	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(exception, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());

	verify(interceptor).beforeConcurrentHandling(this.asyncWebRequest, callable);
}

源代码5 项目： spring-analysis-note 文件： WebAsyncManagerErrorTests.java

@Test
public void startDeferredResultProcessingErrorAndComplete() throws Exception {

	DeferredResult<Integer> deferredResult = new DeferredResult<>();

	DeferredResultProcessingInterceptor interceptor = mock(DeferredResultProcessingInterceptor.class);
	Exception e = new Exception();
	given(interceptor.handleError(this.asyncWebRequest, deferredResult, e)).willReturn(true);

	this.asyncManager.registerDeferredResultInterceptor("interceptor", interceptor);
	this.asyncManager.startDeferredResultProcessing(deferredResult);

	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);
	this.asyncWebRequest.onComplete(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(e, this.asyncManager.getConcurrentResult());

	verify(interceptor).beforeConcurrentHandling(this.asyncWebRequest, deferredResult);
	verify(interceptor).preProcess(this.asyncWebRequest, deferredResult);
	verify(interceptor).afterCompletion(this.asyncWebRequest, deferredResult);
}

源代码6 项目： spring-analysis-note 文件： WebAsyncManagerErrorTests.java

@Test
public void startDeferredResultProcessingErrorAndResumeThroughCallback() throws Exception {

	final DeferredResult<Throwable> deferredResult = new DeferredResult<>();
	deferredResult.onError(new Consumer<Throwable>() {
		@Override
		public void accept(Throwable t) {
			deferredResult.setResult(t);
		}
	});

	this.asyncManager.startDeferredResultProcessing(deferredResult);

	Exception e = new Exception();
	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(e, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码7 项目： spring-analysis-note 文件： WebAsyncManagerErrorTests.java

@Test
public void startDeferredResultProcessingErrorAndResumeThroughInterceptor() throws Exception {

	DeferredResult<Integer> deferredResult = new DeferredResult<>();

	DeferredResultProcessingInterceptor interceptor = new DeferredResultProcessingInterceptor() {
		@Override
		public <T> boolean handleError(NativeWebRequest request, DeferredResult<T> result, Throwable t)
				throws Exception {
			result.setErrorResult(t);
			return true;
		}
	};

	this.asyncManager.registerDeferredResultInterceptor("interceptor", interceptor);
	this.asyncManager.startDeferredResultProcessing(deferredResult);

	Exception e = new Exception();
	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(e, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码8 项目： spring-analysis-note 文件： WebAsyncManagerErrorTests.java

@Test
public void startDeferredResultProcessingAfterException() throws Exception {

	DeferredResult<Integer> deferredResult = new DeferredResult<>();
	final Exception exception = new Exception();

	DeferredResultProcessingInterceptor interceptor = new DeferredResultProcessingInterceptor() {
		@Override
		public <T> boolean handleError(NativeWebRequest request, DeferredResult<T> result, Throwable t)
				throws Exception {
			throw exception;
		}
	};

	this.asyncManager.registerDeferredResultInterceptor("interceptor", interceptor);
	this.asyncManager.startDeferredResultProcessing(deferredResult);

	Exception e = new Exception();
	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(e, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码9 项目： spring-analysis-note 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startCallableProcessingTimeoutAndResumeThroughCallback() throws Exception {

	StubCallable callable = new StubCallable();
	WebAsyncTask<Object> webAsyncTask = new WebAsyncTask<>(callable);
	webAsyncTask.onTimeout(new Callable<Object>() {
		@Override
		public Object call() throws Exception {
			return 7;
		}
	});

	this.asyncManager.startCallableProcessing(webAsyncTask);

	this.asyncWebRequest.onTimeout(ASYNC_EVENT);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(7, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码10 项目： spring-analysis-note 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startCallableProcessingAfterTimeoutException() throws Exception {

	StubCallable callable = new StubCallable();
	Exception exception = new Exception();

	CallableProcessingInterceptor interceptor = mock(CallableProcessingInterceptor.class);
	given(interceptor.handleTimeout(this.asyncWebRequest, callable)).willThrow(exception);

	this.asyncManager.registerCallableInterceptor("timeoutInterceptor", interceptor);
	this.asyncManager.startCallableProcessing(callable);

	this.asyncWebRequest.onTimeout(ASYNC_EVENT);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(exception, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());

	verify(interceptor).beforeConcurrentHandling(this.asyncWebRequest, callable);
}

源代码11 项目： spring-analysis-note 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startDeferredResultProcessingTimeoutAndResumeThroughCallback() throws Exception {

	final DeferredResult<Integer> deferredResult = new DeferredResult<>();
	deferredResult.onTimeout(new Runnable() {
		@Override
		public void run() {
			deferredResult.setResult(23);
		}
	});

	this.asyncManager.startDeferredResultProcessing(deferredResult);

	AsyncEvent event = null;
	this.asyncWebRequest.onTimeout(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(23, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码12 项目： spring-analysis-note 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startDeferredResultProcessingTimeoutAndResumeThroughInterceptor() throws Exception {

	DeferredResult<Integer> deferredResult = new DeferredResult<>();

	DeferredResultProcessingInterceptor interceptor = new DeferredResultProcessingInterceptor() {
		@Override
		public <T> boolean handleTimeout(NativeWebRequest request, DeferredResult<T> result) throws Exception {
			result.setErrorResult(23);
			return true;
		}
	};

	this.asyncManager.registerDeferredResultInterceptor("interceptor", interceptor);
	this.asyncManager.startDeferredResultProcessing(deferredResult);

	AsyncEvent event = null;
	this.asyncWebRequest.onTimeout(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(23, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码13 项目： spring-analysis-note 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startDeferredResultProcessingAfterTimeoutException() throws Exception {

	DeferredResult<Integer> deferredResult = new DeferredResult<>();
	final Exception exception = new Exception();

	DeferredResultProcessingInterceptor interceptor = new DeferredResultProcessingInterceptor() {
		@Override
		public <T> boolean handleTimeout(NativeWebRequest request, DeferredResult<T> result) throws Exception {
			throw exception;
		}
	};

	this.asyncManager.registerDeferredResultInterceptor("interceptor", interceptor);
	this.asyncManager.startDeferredResultProcessing(deferredResult);

	AsyncEvent event = null;
	this.asyncWebRequest.onTimeout(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(exception, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码14 项目： java-technology-stack 文件： WebAsyncManagerErrorTests.java

@Test
public void startCallableProcessingErrorAndComplete() throws Exception {
	StubCallable callable = new StubCallable();

	CallableProcessingInterceptor interceptor = mock(CallableProcessingInterceptor.class);
	Exception e = new Exception();
	given(interceptor.handleError(this.asyncWebRequest, callable, e)).willReturn(RESULT_NONE);

	this.asyncManager.registerCallableInterceptor("interceptor", interceptor);
	this.asyncManager.startCallableProcessing(callable);

	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);
	this.asyncWebRequest.onComplete(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(e, this.asyncManager.getConcurrentResult());

	verify(interceptor).beforeConcurrentHandling(this.asyncWebRequest, callable);
	verify(interceptor).afterCompletion(this.asyncWebRequest, callable);
}

源代码15 项目： java-technology-stack 文件： WebAsyncManagerErrorTests.java

@Test
public void startCallableProcessingErrorAndResumeThroughCallback() throws Exception {

	StubCallable callable = new StubCallable();
	WebAsyncTask<Object> webAsyncTask = new WebAsyncTask<>(callable);
	webAsyncTask.onError(new Callable<Object>() {
		@Override
		public Object call() throws Exception {
			return 7;
		}
	});

	this.asyncManager.startCallableProcessing(webAsyncTask);

	Exception e = new Exception();
	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(7, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码16 项目： java-technology-stack 文件： WebAsyncManagerErrorTests.java

@Test
public void startCallableProcessingErrorAndResumeThroughInterceptor() throws Exception {

	StubCallable callable = new StubCallable();

	CallableProcessingInterceptor interceptor = mock(CallableProcessingInterceptor.class);
	Exception e = new Exception();
	given(interceptor.handleError(this.asyncWebRequest, callable, e)).willReturn(22);

	this.asyncManager.registerCallableInterceptor("errorInterceptor", interceptor);
	this.asyncManager.startCallableProcessing(callable);

	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(22, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());

	verify(interceptor).beforeConcurrentHandling(this.asyncWebRequest, callable);
}

源代码17 项目： java-technology-stack 文件： WebAsyncManagerErrorTests.java

@Test
public void startCallableProcessingAfterException() throws Exception {

	StubCallable callable = new StubCallable();
	Exception exception = new Exception();

	CallableProcessingInterceptor interceptor = mock(CallableProcessingInterceptor.class);
	Exception e = new Exception();
	given(interceptor.handleError(this.asyncWebRequest, callable, e)).willThrow(exception);

	this.asyncManager.registerCallableInterceptor("errorInterceptor", interceptor);
	this.asyncManager.startCallableProcessing(callable);

	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(exception, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());

	verify(interceptor).beforeConcurrentHandling(this.asyncWebRequest, callable);
}

源代码18 项目： java-technology-stack 文件： WebAsyncManagerErrorTests.java

@Test
public void startDeferredResultProcessingErrorAndComplete() throws Exception {

	DeferredResult<Integer> deferredResult = new DeferredResult<>();

	DeferredResultProcessingInterceptor interceptor = mock(DeferredResultProcessingInterceptor.class);
	Exception e = new Exception();
	given(interceptor.handleError(this.asyncWebRequest, deferredResult, e)).willReturn(true);

	this.asyncManager.registerDeferredResultInterceptor("interceptor", interceptor);
	this.asyncManager.startDeferredResultProcessing(deferredResult);

	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);
	this.asyncWebRequest.onComplete(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(e, this.asyncManager.getConcurrentResult());

	verify(interceptor).beforeConcurrentHandling(this.asyncWebRequest, deferredResult);
	verify(interceptor).preProcess(this.asyncWebRequest, deferredResult);
	verify(interceptor).afterCompletion(this.asyncWebRequest, deferredResult);
}

源代码19 项目： java-technology-stack 文件： WebAsyncManagerErrorTests.java

@Test
public void startDeferredResultProcessingErrorAndResumeThroughCallback() throws Exception {

	final DeferredResult<Throwable> deferredResult = new DeferredResult<>();
	deferredResult.onError(new Consumer<Throwable>() {
		@Override
		public void accept(Throwable t) {
			deferredResult.setResult(t);
		}
	});

	this.asyncManager.startDeferredResultProcessing(deferredResult);

	Exception e = new Exception();
	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(e, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码20 项目： java-technology-stack 文件： WebAsyncManagerErrorTests.java

@Test
public void startDeferredResultProcessingErrorAndResumeThroughInterceptor() throws Exception {

	DeferredResult<Integer> deferredResult = new DeferredResult<>();

	DeferredResultProcessingInterceptor interceptor = new DeferredResultProcessingInterceptor() {
		@Override
		public <T> boolean handleError(NativeWebRequest request, DeferredResult<T> result, Throwable t)
				throws Exception {
			result.setErrorResult(t);
			return true;
		}
	};

	this.asyncManager.registerDeferredResultInterceptor("interceptor", interceptor);
	this.asyncManager.startDeferredResultProcessing(deferredResult);

	Exception e = new Exception();
	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(e, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码21 项目： java-technology-stack 文件： WebAsyncManagerErrorTests.java

@Test
public void startDeferredResultProcessingAfterException() throws Exception {

	DeferredResult<Integer> deferredResult = new DeferredResult<>();
	final Exception exception = new Exception();

	DeferredResultProcessingInterceptor interceptor = new DeferredResultProcessingInterceptor() {
		@Override
		public <T> boolean handleError(NativeWebRequest request, DeferredResult<T> result, Throwable t)
				throws Exception {
			throw exception;
		}
	};

	this.asyncManager.registerDeferredResultInterceptor("interceptor", interceptor);
	this.asyncManager.startDeferredResultProcessing(deferredResult);

	Exception e = new Exception();
	AsyncEvent event = new AsyncEvent(new MockAsyncContext(this.servletRequest, this.servletResponse), e);
	this.asyncWebRequest.onError(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(e, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码22 项目： java-technology-stack 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startCallableProcessingTimeoutAndResumeThroughCallback() throws Exception {

	StubCallable callable = new StubCallable();
	WebAsyncTask<Object> webAsyncTask = new WebAsyncTask<>(callable);
	webAsyncTask.onTimeout(new Callable<Object>() {
		@Override
		public Object call() throws Exception {
			return 7;
		}
	});

	this.asyncManager.startCallableProcessing(webAsyncTask);

	this.asyncWebRequest.onTimeout(ASYNC_EVENT);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(7, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码23 项目： java-technology-stack 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startCallableProcessingAfterTimeoutException() throws Exception {

	StubCallable callable = new StubCallable();
	Exception exception = new Exception();

	CallableProcessingInterceptor interceptor = mock(CallableProcessingInterceptor.class);
	given(interceptor.handleTimeout(this.asyncWebRequest, callable)).willThrow(exception);

	this.asyncManager.registerCallableInterceptor("timeoutInterceptor", interceptor);
	this.asyncManager.startCallableProcessing(callable);

	this.asyncWebRequest.onTimeout(ASYNC_EVENT);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(exception, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());

	verify(interceptor).beforeConcurrentHandling(this.asyncWebRequest, callable);
}

源代码24 项目： java-technology-stack 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startDeferredResultProcessingTimeoutAndResumeThroughCallback() throws Exception {

	final DeferredResult<Integer> deferredResult = new DeferredResult<>();
	deferredResult.onTimeout(new Runnable() {
		@Override
		public void run() {
			deferredResult.setResult(23);
		}
	});

	this.asyncManager.startDeferredResultProcessing(deferredResult);

	AsyncEvent event = null;
	this.asyncWebRequest.onTimeout(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(23, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码25 项目： java-technology-stack 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startDeferredResultProcessingTimeoutAndResumeThroughInterceptor() throws Exception {

	DeferredResult<Integer> deferredResult = new DeferredResult<>();

	DeferredResultProcessingInterceptor interceptor = new DeferredResultProcessingInterceptor() {
		@Override
		public <T> boolean handleTimeout(NativeWebRequest request, DeferredResult<T> result) throws Exception {
			result.setErrorResult(23);
			return true;
		}
	};

	this.asyncManager.registerDeferredResultInterceptor("interceptor", interceptor);
	this.asyncManager.startDeferredResultProcessing(deferredResult);

	AsyncEvent event = null;
	this.asyncWebRequest.onTimeout(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(23, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码26 项目： java-technology-stack 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startDeferredResultProcessingAfterTimeoutException() throws Exception {

	DeferredResult<Integer> deferredResult = new DeferredResult<>();
	final Exception exception = new Exception();

	DeferredResultProcessingInterceptor interceptor = new DeferredResultProcessingInterceptor() {
		@Override
		public <T> boolean handleTimeout(NativeWebRequest request, DeferredResult<T> result) throws Exception {
			throw exception;
		}
	};

	this.asyncManager.registerDeferredResultInterceptor("interceptor", interceptor);
	this.asyncManager.startDeferredResultProcessing(deferredResult);

	AsyncEvent event = null;
	this.asyncWebRequest.onTimeout(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(exception, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码27 项目： spring4-understanding 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startCallableProcessingTimeoutAndResumeThroughCallback() throws Exception {

	StubCallable callable = new StubCallable();
	WebAsyncTask<Object> webAsyncTask = new WebAsyncTask<Object>(callable);
	webAsyncTask.onTimeout(new Callable<Object>() {
		@Override
		public Object call() throws Exception {
			return 7;
		}
	});

	this.asyncManager.startCallableProcessing(webAsyncTask);

	this.asyncWebRequest.onTimeout(ASYNC_EVENT);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(7, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码28 项目： spring4-understanding 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startCallableProcessingAfterTimeoutException() throws Exception {

	StubCallable callable = new StubCallable();
	Exception exception = new Exception();

	CallableProcessingInterceptor interceptor = mock(CallableProcessingInterceptor.class);
	given(interceptor.handleTimeout(this.asyncWebRequest, callable)).willThrow(exception);

	this.asyncManager.registerCallableInterceptor("timeoutInterceptor", interceptor);
	this.asyncManager.startCallableProcessing(callable);

	this.asyncWebRequest.onTimeout(ASYNC_EVENT);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(exception, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());

	verify(interceptor).beforeConcurrentHandling(this.asyncWebRequest, callable);
}

源代码29 项目： spring4-understanding 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startDeferredResultProcessingTimeoutAndResumeThroughCallback() throws Exception {

	final DeferredResult<Integer> deferredResult = new DeferredResult<Integer>();
	deferredResult.onTimeout(new Runnable() {
		@Override
		public void run() {
			deferredResult.setResult(23);
		}
	});

	this.asyncManager.startDeferredResultProcessing(deferredResult);

	AsyncEvent event = null;
	this.asyncWebRequest.onTimeout(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(23, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

源代码30 项目： spring4-understanding 文件： WebAsyncManagerTimeoutTests.java

@Test
public void startDeferredResultProcessingTimeoutAndResumeThroughInterceptor() throws Exception {

	DeferredResult<Integer> deferredResult = new DeferredResult<Integer>();

	DeferredResultProcessingInterceptor interceptor = new DeferredResultProcessingInterceptorAdapter() {
		@Override
		public <T> boolean handleTimeout(NativeWebRequest request, DeferredResult<T> result) throws Exception {
			result.setErrorResult(23);
			return true;
		}
	};

	this.asyncManager.registerDeferredResultInterceptor("interceptor", interceptor);
	this.asyncManager.startDeferredResultProcessing(deferredResult);

	AsyncEvent event = null;
	this.asyncWebRequest.onTimeout(event);

	assertTrue(this.asyncManager.hasConcurrentResult());
	assertEquals(23, this.asyncManager.getConcurrentResult());
	assertEquals("/test", ((MockAsyncContext) this.servletRequest.getAsyncContext()).getDispatchedPath());
}

方法所在类

org.springframework.web.context.request.async.StandardServletAsyncWebRequest