Found 29 packages
Provides support for Language-Integrated Query (LINQ) over IAsyncEnumerable<T> sequences.
Interactive Extensions Async Library used to express queries over asynchronous enumerable sequences.
Provides support for Language-Integrated Query (LINQ) over IAsyncQueryable<T> sequences with query providers.
Asynchronous sequences for F#
Interactive Extensions Async Providers Library used to build query providers and express queries over async enumerable sequences.
IAsyncEnumerable interface definition, and some LINQ function for it
This project enhances Async LINQ to Objects with the following methods: AggregateRight, AssertCount, AtLeast, AtMost, Choose, CollectionEqual, CompareCount, ConcurrentMerge, Consume, CountBetween, CountBy, CountDown, DenseRank, DenseRankBy, DistinctBy, ElementAt, EndsWith, Exactly, ExceptBy, FallbackIfEmpty, FillBackward, FillForward, Fold, From, Generate, GroupAdjacent, Index, IndexBy, Insert, Interleave, OrderBy, Pad, PadStart, PartialSort, PartialSortBy, Random, Rank, RankBy, RunLengthEncode, ScanBy, ScanRight, Segment, Sequence, SkipUntil, SortedMerge, Split, StartsWith, TagFirstLast, Take, TakeEvery, TakeUntil, ThenBy, Where, Window, WindowLeft, WindowRight, ZipLongest, ZipMap, ZipShortest
An asynchronous implementation of the iterator pattern for .NET Standard 2.0.
This library brings C#'s concept of 'await foreach' to F#, with a seamless implementation of IAsyncEnumerable<'T>. The 'taskSeq' computation expression adds support for awaitable asynchronous sequences with similar ease of use and performance to F#'s 'task' CE, with minimal overhead through ValueTask under the hood. TaskSeq brings 'seq' and 'task' together in a safe way. Generates optimized IL code through resumable state machines, and comes with a comprehensive set of functions in module 'TaskSeq'. See README for documentation and more info.
LINQ-like fluent extension methods for asynchronously enumerable sequences.
Asynchronous sequences for F#
Additional asynchronous functionality for the Bogosoft.Data library.
Adds an AsyncEnumerableBuilder to incrementally construct an async enumerable sequence out of building blocks.
Asynchronous sequences for F#, forked by Johann Deneux with a suggested fix for a performance issue in AsyncSeq.cache
PullStream.Json allows to create lazy System.IO.Stream that contains json array of sequence of elements
A flexible and extensible task sequencing library for .NET that allows you to define, execute, and monitor ordered task pipelines. Supports asynchronous execution, cancellation tokens, error handling, and progress reporting for building robust workflows.
[.NET 4.6.1+] - DisposableObservable: a class for creating Observable sequences with TPL easily as Observable.Create - [IObservable].Serialize: wrap all subscriptions into a single ISubject against the sourcing observable - [IObservable].AsAsync: execute all functions on TPL - [IObservable].Fork: add another subscription to the observable creating a new child observable stream - [IObservable].Where(filter, elseObservable): apply the where in the usual way, and generate an Else observable to continue work in the other case - [IObservable].ToJson: serialize in Json all values - [IObservable].ToCSV: serialize in CSV columns all values (configurable delimiter) - [IObservable].OnLastOrDefault: do something when observable completes - ObservableStreamReader: route binary data from a Stream to subscribers
Provides asynchronous LINQ extensions and utilities for working with IAsyncEnumerable<T> sequences, including bridging between synchronous and asynchronous enumeration models.
Sequence workflow library for javascript, can run on browser or on node. can manage deep nested callbacks or list of functions that needs to run in sequence, with support for loops and logical operations. also supports async functions to be called by the flow, and then resume flow when async operation completed.
PullStream.Csv allows to create lazy System.IO.Stream that contains csv representation of sequence of elements