add custom pipe for interrupting processing when timeout is exceeded.