[logdog] Stream view explicitly cancels request.

web/inc/logdog-stream-view/fetcher.ts

 /*
   Copyright 2016 The LUCI Authors. All rights reserved.
   Use)) of this source code is governed under the Apache License, Version 2.0
   that can be found in the LICENSE file.
 */
 
 ///<reference path="../logdog-stream/logdog.ts" />
 ///<reference path="../logdog-stream/client.ts" />
 ///<reference path="../luci-operation/operation.ts" />
 
@@ skipping 329 matching lines @@
       }
 
       if (this.debug) {
         console.log('logdog.Logs.Get:', request);
       }
 
       // Perform our Get, waiting until the stream actually exists.
       let missingRetry = new luci.RetryIterator(Fetcher.missingRetry);
       let resp = await missingRetry.do(() => {
         ctx.updateStatus(FetchStatus.LOADING);
-        return this.client.get(request);
+        return this.client.get(ctx.op, request);
       }, this.doRetryIfMissing(ctx));
       let fr = FetchResult.make(resp, this.lastDesc);
       return this.afterProcessResult(ctx, fr);
     }
 
     private async doTail(ctx: FetchContext) {
       let missingRetry = new luci.RetryIterator(Fetcher.missingRetry);
       let resp = await missingRetry.do(() => {
         ctx.updateStatus(FetchStatus.LOADING);
         let needsState = (this.terminalIndex < 0);
-        return this.client.tail(this.stream, needsState);
+        return this.client.tail(ctx.op, this.stream, needsState);
       }, this.doRetryIfMissing(ctx));
 
       let fr = FetchResult.make(resp, this.lastDesc);
       return this.afterProcessResult(ctx, fr);
     }
 
     private afterProcessResult(ctx: FetchContext, fr: FetchResult):
         LogDog.LogEntry[] {
       if (this.debug) {
         if (fr.logs.length) {
@@ skipping 58 matching lines @@
       let loadState: LogDog.LogStreamState|undefined;
       if (resp.state) {
         loadState = LogDog.LogStreamState.make(resp.state);
       }
 
       let logs = (resp.logs || []).map(le => LogDog.LogEntry.make(le, desc));
       return new FetchResult(logs, loadDesc, loadState);
     }
   }
 }