Project Name File Name Usage Source Code Link
RunJS JsPromise.cs task.ContinueWith(t => { object result = null; ManualResetEvent m = new ManualResetEvent(false); runner.BeginInvoke(r => { result = function.CallLateBound(Engine.Global, t.Result); m.Set(); }); m.WaitOne(); return result; }) Link To Source File
RunJS JsPromise.cs task.ContinueWith(t => (object)t.Result) Link To Source File
RunJS JsPromise.cs task.ContinueWith(t => (object)converter(t.Result)) Link To Source File
PrintChar CompendiumClient.cs request.ContinueWith(task => task.Result.Body.ToDetailsNode()) Link To Source File
PrintChar ServiceFactory.cs contentVault.ContinueWith(vault => _CreateRepository(vault, workspace, compendium)) Link To Source File
PrintChar ServiceFactory.cs orchestration.Task.ContinueWith(credentials => LogInToRealService(credentials.Result.Item1, credentials.Result.Item2).Result) Link To Source File
CouchDude GetFileTask.cs httpClient .SendAsync(requestMessage, HttpCompletionOption.ResponseHeadersRead) .ContinueWith( getDistributiveTask => { var response = getDistributiveTask.Result; response.EnsureSuccessStatusCode(); var downloadingFileName = string.Format("{0}.{1}.zip", Guid.NewGuid(), distributiveUri.Segments.LastOrDefault() ?? string.Empty); var tempFile = new FileInfo(Path.Combine(tempDir.FullName, downloadingFileName)); var tempFileWriteStream = tempFile.OpenWrite(); return response.Content .CopyToAsync(tempFileWriteStream) .ContinueWith( copyTask => { copyTask.Wait(); // ensuring exception propagated (is it nessesary?) tempFileWriteStream.Close(); return tempFile; }); }) .Unwrap() .ContinueWith( downloadTask => { httpClient.Dispose(); return downloadTask.Result; }) Link To Source File
CouchDude GetFileTask.cs httpClient .SendAsync(requestMessage, HttpCompletionOption.ResponseHeadersRead) .ContinueWith( getDistributiveTask => { var response = getDistributiveTask.Result; response.EnsureSuccessStatusCode(); var downloadingFileName = string.Format("{0}.{1}.zip", Guid.NewGuid(), distributiveUri.Segments.LastOrDefault() ?? string.Empty); var tempFile = new FileInfo(Path.Combine(tempDir.FullName, downloadingFileName)); var tempFileWriteStream = tempFile.OpenWrite(); return response.Content .CopyToAsync(tempFileWriteStream) .ContinueWith( copyTask => { copyTask.Wait(); // ensuring exception propagated (is it nessesary?) tempFileWriteStream.Close(); return tempFile; }); }) Link To Source File
Modl Materializer.cs reader.ContinueWith(r => { return new Materializer(r.Result, database); }) Link To Source File
Modl Modl.cs AsyncDbAccess.ExecuteScalar(Database, true, query, Database.GetLastIdQuery()).ContinueWith(x => { var id = x.Result; Store.Id = id; StaticCache.Add(id, (M)this, Database); IsIdLoaded = true; return id; }) Link To Source File
Modl Modl.cs IdTask.ContinueWith(_ => true) Link To Source File
Modl Select.cs Materializer.Async(ExecuteAsync(onQueue), DatabaseProvider).ContinueWith(x => x.Result.ReadAndClose()) Link To Source File
Modl Select.cs Materializer.Async(ExecuteAsync(onQueue), DatabaseProvider).ContinueWith(x => x.Result.GetAll()) Link To Source File
BTDB KeyValueDBReplayProxy.cs _db.StartWritingTransaction().ContinueWith(t => { var result = new KeyValueDBReplayTransactionProxy(t.Result, _log, ref _trCounter); lock (_log) { _log.WriteUInt8((byte)KVReplayOperation.StartWritingTransaction); _log.WriteVUInt32(result.TrIndex); _log.FlushBuffer(); } return result; }, TaskContinuationOptions.ExecuteSynchronously) Link To Source File
NextbusNET NextbusAsyncClient.cs ExecuteRequest(request).ContinueWith(x => _parser.ParseVehicle(x.Result.Content)) Link To Source File
NextbusNET NextbusAsyncClient.cs ExecuteRequest(request).ContinueWith(x => _parser.ParseAgencies(x.Result.Content)) Link To Source File
NextbusNET NextbusAsyncClient.cs ExecuteRequest(request).ContinueWith(x => _parser.ParseRoute(x.Result.Content)) Link To Source File
NextbusNET NextbusAsyncClient.cs ExecuteRequest(request).ContinueWith(x => _parser.ParseRouteConfig(x.Result.Content)) Link To Source File
NextbusNET NextbusAsyncClient.cs ExecuteRequest(request).ContinueWith(x => _parser.ParsePrediction(x.Result.Content)) Link To Source File
NextbusNET NextbusAsyncClient.cs ExecuteRequest(request).ContinueWith(x => _parser.ParsePrediction(x.Result.Content)) Link To Source File
NextbusNET NextbusAsyncClient.cs ExecuteRequest(request).ContinueWith(x => _parser.ParseSchedule(x.Result.Content)) Link To Source File
NextbusNET NextbusAsyncClient.cs ExecuteRequest(request).ContinueWith(x => _parser.ParsePrediction(x.Result.Content)) Link To Source File
NextbusNET NextbusAsyncClient.cs tcs.Task.ContinueWith(x => { stopwatch.Stop(); var response = x.Result; if (response.ResponseStatus != ResponseStatus.Completed) { throw new NextbusException(response.ErrorMessage, response.ErrorException); } Log.Debug(string.Format("uri: {0} / time: {1} ms / length: {2}", response.ResponseUri, stopwatch.ElapsedMilliseconds, response.RawBytes.Length)); return response; }) Link To Source File
ILoveLucene TaskExtensions.cs task.ContinueWith(t => { if (t.Exception != null) { callback(t.Exception); } return t.Result; }) Link To Source File
coapp AtomPackageFeed.cs // bring the file local first EnsureFileIsLocal().ContinueWith(antecedent => { if (antecedent.IsFaulted || antecedent.IsCanceled || !antecedent.Result) { Scanned = false; LastScanned = DateTime.MinValue; return false; } Stale = false; // we're good to load the file from the _localLocation var feed = AtomFeed.LoadFile(_localLocation); // since AtomFeeds are so nicely integrated with Package now, we can just get the packages from there :) _packageList.AddRange(feed.Packages); Scanned = true; LastScanned = DateTime.Now; return true; }) Link To Source File
_toolkit_deprecated AtomPackageFeed.cs // bring the file local first EnsureFileIsLocal().ContinueWith(antecedent => { if (antecedent.IsFaulted || antecedent.IsCanceled || !antecedent.Result) { Scanned = false; LastScanned = DateTime.MinValue; return false; } Stale = false; // we're good to load the file from the _localLocation var feed = AtomFeed.LoadFile(_localLocation); // since AtomFeeds are so nicely integrated with Package now, we can just get the packages from there :) _packageList.AddRange(feed.Packages); Scanned = true; LastScanned = DateTime.Now; return true; }) Link To Source File
dotnetUtils HttpClient.cs task.ContinueWith(t => { var stream = t.Result.GetResponseStream(); reportAndCheckToken(0.9); return stream; }) Link To Source File
Filechronization NetworksManager.cs _manager.ConnectTask(address) .ContinueWith(prev => _multiPeerMap.GetOrCreatePeer(net, prev.Result)) Link To Source File
RestBugs EtagMessageHandler.cs base.SendAsync(request, cancellationToken).ContinueWith(task => { Trace.WriteLine("EtagMessageHandler - Task - Not a conditional GET"); var resp = task.Result; resp.Headers.ETag = new EntityTagHeaderValue(_eTagStore.Fetch(request.RequestUri)); return resp; }) Link To Source File
RestBugs EtagMessageHandler.cs base.SendAsync(request, cancellationToken).ContinueWith(task => { Trace.WriteLine("EtagMessageHandler - Task - Conditional GET not matched"); var resp = task.Result; resp.Headers.ETag = new EntityTagHeaderValue(_eTagStore.Fetch(request.RequestUri)); return resp; }) Link To Source File
RestBugs EtagMessageHandler.cs base.SendAsync(request, cancellationToken).ContinueWith(task => { Trace.WriteLine("EtagMessageHandler - Task - Conditional update matched"); var resp = task.Result; resp.Headers.ETag = new EntityTagHeaderValue(_eTagStore.UpdateETagFor(request.RequestUri)); return resp; }) Link To Source File
Par2NET MD5TasksHelper.cs ComputeMD5Hash(filename).ContinueWith((MD5HashTask) => { return ByteArrayToString(MD5HashTask.Result); }) Link To Source File
Par2NET MD5TasksHelper.cs ComputeMD5HashStr(filename).ContinueWith((MD5HashStrTask) => { return CompareHashes(MD5HashStrTask.Result, verifyHash); }) Link To Source File
tdameritrade WebRequestExtensions.cs webRequest.GetResponseAsync().ContinueWith(response => { return response.Result.GetResponseStream().ReadAllBytesAsync(); }) Link To Source File
tdameritrade WebRequestExtensions.cs webRequest.GetRequestStreamAsync().ContinueWith(stream => { return stream.Result.WriteAsync(buffer, 0, buffer.Length); }) Link To Source File
tdameritrade WebRequestExtensions.cs webRequest.GetResponseAsync().ContinueWith(response => { return response.Result.GetResponseStream().ReadXmlAsync(); }) Link To Source File
tdameritrade TDAClient.cs GetTextAsync(url) .ContinueWith(task => { if (new string[] { "LoggedOn", "InvalidSession" }.Contains(task.Result)) { return new Response(); } return new Response(new ResponseError("Unexpected response received from the web service.")); }) Link To Source File
tdameritrade TDAClient.cs webRequest.DownloadDataAsync().ContinueWith(result => { return Encoding.ASCII.GetString(result.Result); }) Link To Source File
tdameritrade TDAClient.cs webRequest.DownloadDataAsync().ContinueWith(result => { return Encoding.ASCII.GetString(result.Result); }) Link To Source File
SwarmIntelligence FileAsync.cs encoded.ContinueWith(t => WriteAllBytes(path, t.Result)) Link To Source File
SwarmIntelligence WebRequestExtensions.cs webRequest.GetResponseAsync().ContinueWith(response => { return response.Result.GetResponseStream().ReadAllBytesAsync(); }) Link To Source File
ODataLib ODataResponseMessage.cs task.ContinueWith((streamTask) => { Stream messageStream = streamTask.Result; ValidateMessageStream(messageStream); return messageStream; }) Link To Source File
ODataLib ODataRequestMessage.cs task.ContinueWith((streamTask) => { Stream messageStream = streamTask.Result; ValidateMessageStream(messageStream); return messageStream; }) Link To Source File
WCFWeb HttpContentExtensionMethods.cs objectContent.ReadAsAsync().ContinueWith((t) => { objectContent.Dispose(); return t.Result; }) Link To Source File
WCFWeb HttpContentExtensionMethods.cs objectContent.ReadAsAsync().ContinueWith((t) => { objectContent.Dispose(); return t.Result; }) Link To Source File
WCFWeb HttpContentExtensionMethods.cs objectContent.ReadAsOrDefaultAsync().ContinueWith((t) => { objectContent.Dispose(); return t.Result; }) Link To Source File
WCFWeb HttpContentExtensionMethods.cs objectContent.ReadAsOrDefaultAsync().ContinueWith((t) => { objectContent.Dispose(); return t.Result; }) Link To Source File
WCFWeb HttpContentExtensionMethods.cs objectContent.ReadAsAsync().ContinueWith((t) => { objectContent.Dispose(); return t.Result; }) Link To Source File
WCFWeb HttpContentExtensionMethods.cs objectContent.ReadAsAsync().ContinueWith((t) => { objectContent.Dispose(); return t.Result; }) Link To Source File
WCFWeb HttpContentExtensionMethods.cs objectContent.ReadAsOrDefaultAsync().ContinueWith((t) => { objectContent.Dispose(); return t.Result; }) Link To Source File
WCFWeb HttpContentExtensionMethods.cs objectContent.ReadAsOrDefaultAsync().ContinueWith((t) => { objectContent.Dispose(); return t.Result; }) Link To Source File
WCFWeb ObjectContent.cs formatter.ReadFromStreamAsync( this.Type, httpContent.ContentReadStream, this.Headers) .ContinueWith((task) => { object value = task.Result; this.CacheValueAndDisposeWrappedHttpContent(value); return value; }) Link To Source File
WCFWeb ObjectContent.cs formatter.ReadFromStreamAsync( this.Type, httpContent.ContentReadStream, this.Headers) .ContinueWith((task) => { T value = (T)task.Result; this.CacheValueAndDisposeWrappedHttpContent(value); return value; }) Link To Source File
coapp CoTaskFactory.cs tcs.Task.ContinueWith(antecedent => { return endMethod(antecedent.Result); }) Link To Source File
coapp CoTaskFactory.cs tcs.Task.ContinueWith(antecedent => { return endMethod(antecedent.Result); }) Link To Source File
coapp CoTaskFactory.cs tcs.Task.ContinueWith(antecedent => { return endMethod(antecedent.Result); }) Link To Source File
coapp CoTaskFactory.cs tcs.Task.ContinueWith(antecedent => { return endMethod(antecedent.Result); }) Link To Source File
coapp CoTaskFactory.cs tcs.Task.ContinueWith(antecedent => { return endMethod(antecedent.Result); }) Link To Source File
coapp CoTaskFactory.cs tcs.Task.ContinueWith(antecedent => { return continuationFunction(antecedent.Result); }) Link To Source File
coapp CoTaskFactory.cs tcs.Task.ContinueWith(antecedent => { return endMethod(antecedent.Result); }) Link To Source File
coapp CoTaskFactory.cs tcs.Task.ContinueWith(antecedent => { return endMethod(antecedent.Result); }) Link To Source File
coapp CoTaskFactory.cs tcs.Task.ContinueWith(antecedent => { return endMethod(antecedent.Result); }) Link To Source File
coapp CoTaskFactory.cs tcs.Task.ContinueWith(antecedent => { return endMethod(antecedent.Result); }) Link To Source File
coapp CoTaskFactory.cs tcs.Task.ContinueWith(antecedent => { return endMethod(antecedent.Result); }) Link To Source File
nji NjiApi.cs DownloadAsync(package, TempDir, packageFilename, cancellationToken) .ContinueWith(downloadTask => { if (downloadTask.IsFaulted) throw downloadTask.Exception.GetBaseException(); var downloadFilePath = downloadTask.Result; return Extract(downloadFilePath, destinationDir); }) Link To Source File
nji NjiApi.cs GetInstalledPackagesAsync(cancellationToken) .ContinueWith(t => { if (t.IsFaulted) throw t.Exception.GetBaseException(); return UpdateAsync(t.Result.Values, cancellationToken); }) Link To Source File
ravendb AsyncServerClient.cs request.ReadResponseJsonAsync() .ContinueWith(readJsonTask => { return readJsonTask.Result.Value("index"); }) Link To Source File
ravendb AsyncServerClient.cs request.ReadResponseJsonAsync() .ContinueWith(task => CompleteMultiGetAsync(task)) Link To Source File
ravendb HttpJsonRequest.cs Task.Factory.FromAsync(webRequest.BeginGetResponse, webRequest.EndGetResponse, null) .ContinueWith(task => ReadStringInternal(() => task.Result)) .ContinueWith(task => { var webException = task.Exception.ExtractSingleInnerException() as WebException; if (webException == null || retries >= 3) return task;// effectively throw var httpWebResponse = webException.Response as HttpWebResponse; if (httpWebResponse == null || httpWebResponse.StatusCode != HttpStatusCode.Unauthorized) return task; // effectively throw var authorizeResponse = HandleUnauthorizedResponseAsync(httpWebResponse); if (authorizeResponse == null) return task; // effectively throw return authorizeResponse .ContinueWith(_ => { _.Wait(); //throw on error return InternalReadResponseStringAsync(retries + 1); }) .Unwrap(); }) Link To Source File
ravendb HttpJsonRequest.cs Task.Factory.FromAsync(webRequest.BeginGetResponse, webRequest.EndGetResponse, null) .ContinueWith(task => ReadStringInternal(() => task.Result)) Link To Source File
ravendb AsyncDocumentSession.cs AsyncDatabaseCommands.GetAsync(id) .ContinueWith(task => { if (loadOperation.SetResult(task.Result) == false) return Task.Factory.StartNew(() => loadOperation.Complete()); return CompleteLoadAsync(id, loadOperation); }) Link To Source File
ravendb AsyncDocumentSession.cs AsyncDatabaseCommands.GetAsync(ids, includes) .ContinueWith(t => { if (multiLoadOperation.SetResult(t.Result) == false) return Task.Factory.StartNew(() => multiLoadOperation.Complete()); return LoadAsyncInternal(ids, includes, multiLoadOperation); }) Link To Source File
ravendb AbstractDocumentQuery.cs InitAsync() .ContinueWith(x => x.Result.CurrentQueryResults.CreateSnapshot()) Link To Source File
ravendb AbstractDocumentQuery.cs ExecuteActualQueryAsync() .ContinueWith(t => ProcessEnumerator(t)) Link To Source File
ravendb AbstractDocumentQuery.cs InitAsync() .ContinueWith(t => ProcessEnumerator(t)) .Unwrap() .ContinueWith(t => Tuple.Create(t.Result.Item1.CurrentQueryResults, t.Result.Item2)) Link To Source File
ravendb AbstractDocumentQuery.cs InitAsync() .ContinueWith(t => ProcessEnumerator(t)) Link To Source File
ravendb TaskExtensions.cs parent.ContinueWith(task => { if (task.IsFaulted) { var exception = task.Exception.ExtractSingleInnerException(); if (exception is SecurityException) throw new WebException("Could not contact server./r/nGot security error because RavenDB wasn't able to contact the database to get ClientAccessPolicy.xml permission.", exception); } return task; }) Link To Source File
ravendb LinqExtensions.cs documentQuery.ToListAsync() .ContinueWith(task => task.Result.Item2) Link To Source File
ravendb AsyncServerClient.cs httpJsonRequest.ReadResponseJsonAsync() .ContinueWith(replyTask => convention.CreateSerializer().Deserialize(new RavenJTokenReader(replyTask.Result))) Link To Source File
ravendb AsyncServerClient.cs request.ReadResponseJsonAsync() .ContinueWith(task => convention.CreateSerializer().Deserialize(new RavenJTokenReader(task.Result))) Link To Source File
ravendb AsyncServerClient.cs request.ReadResponseJsonAsync() .ContinueWith(task => convention.CreateSerializer().Deserialize(new RavenJTokenReader(task.Result))) Link To Source File
ravendb AsyncServerClient.cs request.ReadResponseJsonAsync() .ContinueWith(task => convention.CreateSerializer().Deserialize(new RavenJTokenReader(task.Result))) Link To Source File
ravendb AsyncServerClient.cs request.ReadResponseJsonAsync() .ContinueWith(task => { var json = (RavenJObject) task.Result; return json.JsonDeserialization>>(); }) Link To Source File
ravendb AsyncServerClient.cs request.ReadResponseJsonAsync() .ContinueWith(task => CompleteMultiGet(task)) Link To Source File
ravendb AsyncServerClient.cs request.WriteAsync(new JArray(keys).ToString(Formatting.None)) .ContinueWith(writeTask => request.ReadResponseJsonAsync()) .ContinueWith(task => CompleteMultiGet(task.Result)) Link To Source File
ravendb AsyncServerClient.cs url.Docs(start, pageSize) .NoCache() .ToJsonRequest(this, credentials, convention) .ReadResponseJsonAsync() .ContinueWith(task => ((RavenJArray)task.Result) .Cast() .ToJsonDocuments() .ToArray()) Link To Source File
ravendb AsyncServerClient.cs url.DocsStartingWith(prefix, start, pageSize) .NoCache() .ToJsonRequest(this, credentials, convention) .ReadResponseJsonAsync() .ContinueWith(task => ((RavenJArray)task.Result) .Cast() .ToJsonDocuments() .ToArray()) Link To Source File
ravendb AsyncServerClient.cs request.ReadResponseJsonAsync() .ContinueWith(task1 => { try { return convention.CreateSerializer().Deserialize(new RavenJTokenReader(task1.Result)); } catch (AggregateException e) { var webexception = e.ExtractSingleInnerException() as WebException; if (ShouldThrowForPutAsync(webexception)) throw; throw ThrowConcurrencyException(webexception); } catch (WebException e) { if (ShouldThrowForPutAsync(e)) throw; throw ThrowConcurrencyException(e); } }) Link To Source File
ravendb AsyncServerClient.cs request .ReadResponseJsonAsync() .ContinueWith(readStrTask => AttemptToProcessResponse(() => { //NOTE: JsonConvert.DeserializeAnonymousType() doesn't work in Silverlight because the ctor is private! var obj = convention.CreateSerializer().Deserialize(new RavenJTokenReader(readStrTask.Result)); return obj.Index; })) Link To Source File
ravendb AsyncServerClient.cs url.IndexNames(start, pageSize) .NoCache() .ToJsonRequest(this, credentials, convention) .ReadResponseJsonAsync() .ContinueWith(task => { var json = ((RavenJArray)task.Result); return json.Select(x => x.Value()).ToArray(); }) Link To Source File
ravendb AsyncServerClient.cs req.WriteAsync(jArray.ToString(Formatting.None)) .ContinueWith(writeTask => req.ReadResponseJsonAsync()) .Unwrap() .ContinueWith(task => { RavenJToken response; try { response = task.Result; } catch (WebException e) { var httpWebResponse = e.Response as HttpWebResponse; if (httpWebResponse == null || httpWebResponse.StatusCode != HttpStatusCode.Conflict) throw; throw ThrowConcurrencyException(e); } return convention.CreateSerializer().Deserialize(new RavenJTokenReader(response)); }) Link To Source File
ravendb AsyncServerClient.cs url.Stats() .NoCache() .ToJsonRequest(this, credentials, convention) .ReadResponseJsonAsync() .ContinueWith(task => { var jo = ((RavenJObject)task.Result); return jo.Deserialize(convention); }) Link To Source File
ravendb AsyncServerClient.cs url.Databases() .NoCache() .ToJsonRequest(this, credentials, convention) .ReadResponseJsonAsync() .ContinueWith(task => { var json = ((RavenJArray)task.Result); return json .Select(x => x.Value("@metadata").Value("@id").Replace("Raven/Databases/", string.Empty)) .ToArray(); }) Link To Source File
ravendb AsyncServerClient.cs url.Terms(index, field, fromValue, pageSize) .NoCache() .ToJsonRequest(this, credentials, convention) .ReadResponseJsonAsync() .ContinueWith(task => { var json = ((RavenJArray)task.Result); return json.Select(x => x.Value()).ToArray(); }) Link To Source File
ravendb HttpJsonRequest.cs ReadResponseStringAsync() .ContinueWith(task => RavenJToken.Parse(task.Result)) Link To Source File
ravendb HttpJsonRequest.cs webRequest .GetResponseAsync() .ConvertSecurityExceptionToServerNotFound() .AddUrlIfFaulting(webRequest.RequestUri) .ContinueWith(t => ReadStringInternal(() => t.Result)) .ContinueWith(task => RetryIfNeedTo(task, ReadResponseStringAsync)) Link To Source File
ravendb HttpJsonRequest.cs webRequest .GetResponseAsync() .ConvertSecurityExceptionToServerNotFound() .AddUrlIfFaulting(webRequest.RequestUri) .ContinueWith(t => ReadStringInternal(() => t.Result)) Link To Source File
ravendb HttpJsonRequest.cs unauthorizedResponseAsync.ContinueWith(task => RecreateWebRequest(task.Result)) Link To Source File
ravendb HttpJsonRequest.cs webRequest .GetResponseAsync() .ConvertSecurityExceptionToServerNotFound() .AddUrlIfFaulting(webRequest.RequestUri) .ContinueWith(t => ReadResponse(() => t.Result, ConvertStreamToBytes)) .ContinueWith(task => RetryIfNeedTo(task, ReadResponseBytesAsync)) Link To Source File
ravendb HttpJsonRequest.cs webRequest .GetResponseAsync() .ConvertSecurityExceptionToServerNotFound() .AddUrlIfFaulting(webRequest.RequestUri) .ContinueWith(t => ReadResponse(() => t.Result, ConvertStreamToBytes)) Link To Source File
ravendb HttpJsonRequest.cs webRequest.GetRequestStreamAsync() .ContinueWith(task => { var dataStream = task.Result; var streamWriter = new StreamWriter(dataStream, Encoding.UTF8); return streamWriter.WriteAsync(data) .ContinueWith(writeTask => { streamWriter.Dispose(); dataStream.Dispose(); return writeTask; }).Unwrap(); }) Link To Source File
ravendb InvocationExtensions.cs parent.ContinueWith(task => { if (task.Result == false) return false; action(); return true; }) Link To Source File
ravendb InvocationExtensions.cs parent.ContinueWith(task => action(task.Result)) Link To Source File
ravenmq StreamExtension.cs stream .ReadBuffer() .ContinueWith(readLenTask => readLenTask.Result.ToJObject()) Link To Source File
SLRSyncUploader FileProcessor.cs Task.Factory.StartNew(() => CalculateHashes(buffer, offSetPosition, bytesToRead, config)) .ContinueWith( outHash => resultDictionary.TryAdd(outHash.Result.WeakHash, outHash.Result)) Link To Source File
snippets TaskParallelism.cs Task.Factory.StartNew(() => GetData()) .ContinueWith(x => Analysis(x.Result)) .ContinueWith(y => Report(y.Result)) Link To Source File
snippets TaskParallelism.cs Task.Factory.StartNew(() => GetData()) .ContinueWith(x => Analysis(x.Result)) Link To Source File
torshify-client ImageMapFrame.xaml.cs Task.Factory .StartNew(FindAllImageFiles, imageFolder) .ContinueWith(t => CreateMapData(t.Result)) Link To Source File
torshify-client SimilarArtistViewModel.cs Task> .Factory .StartNew(FindRootArtistInformation, artistName) .ContinueWith(t => FindSimilarArtists(t.Result)) .ContinueWith(t => _dispatcher.BeginInvoke(new Action(() => Graph.CenterObject = t.Result))) Link To Source File
torshify-client SimilarArtistViewModel.cs Task> .Factory .StartNew(FindRootArtistInformation, artistName) .ContinueWith(t => FindSimilarArtists(t.Result)) Link To Source File