Permalink
Browse files

fix(timeout): return observable

  • Loading branch information...
jkuri committed Sep 11, 2017
1 parent 641d3fd commit 85e024d0b88002cf944bb7b1e5dbac791b80a88a
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/api/process.ts
@@ -127,8 +127,8 @@ export function startBuildProcess(
.concat(...scriptCommands.map(cmd => executeInContainer(name, cmd)))
.concat(...deployCommands.map(cmd => executeInContainer(name, cmd)))
.timeoutWith(idleTimeout, Observable.throw(new Error('command timeout')))
.merge(Observable.timer(jobTimeout).timeInterval().mergeMap((): any => {
Observable.throw('job timeout');
.merge(Observable.timer(10000).timeInterval().mergeMap(() => {
return Observable.throw('job timeout');
}))
.subscribe((event: ProcessOutput) => {
observer.next(event);

0 comments on commit 85e024d

Please sign in to comment.