Interactive Extensions (Ix) is a library providing extensions to the LINQ to Objects query operators, influenced by query operators introduced in Reactive Extensions (Rx). Interactive Extensions (Ix) introduces a set of additional LINQ to Objects query operators, based on the work done in the Reactive Extensions (Rx).
Questions tagged [system.interactive]
9 questions
8
votes
3 answers
Rx: EnumerableEx.For() vs Enumerable.SelectMany()
System.Interactive.dll includes a For() method with the following implementation:
IEnumerable For(
IEnumerable source,
Func> resultSelector)
{
return…
dahlbyk
- 75,175
- 8
- 100
- 122
8
votes
1 answer
System.Interactive: Difference between Memoize() and MemoizeAll()?
In System.Interactive.dll (v1.0.2521.0) from Reactive Extensions, EnumerableEx has both a Memoize method and a MemoizeAll method. The API documentation is identical for both of them:
Creates an enumerable that enumerates the original enumerable…
Joel Mueller
- 28,324
- 9
- 63
- 88
7
votes
5 answers
How can I "adapt" a Task> to IAsyncEnumerable?
I'm incrementally introducing Ix.NET into a legacy project. I have a number of storage-level APIs that return Task>, but I want to adapt them to IAsyncEnumerable for consumption in the rest of the system. It seems like there…
Kevin Halverson
- 547
- 6
- 7
7
votes
1 answer
Is there an example of Ix.NET (System.Interactive) somewhere?
I have an async method, say:
public async Task GetAsync()
{
}
and would be called from:
public async Task> GetAllAsync()
{
foreach (var item in something)
{
var result = await GetAsync();
yield return…
nawfal
- 70,104
- 56
- 326
- 368
2
votes
1 answer
Reactive Extensions (Rx) for Silverlight - Where is System.Interactive.dll moved to?
I've just installed the newest Release (v1.1.10425) of Rx for Silverlight 4 and 5 (Beta). I've seen that the package is missing 3 DLLs I've used in my projects in the past:
System.CoreEx.dll
System.Interactive.dll
System.Observable.dll
What I'm…
0xbadf00d
- 17,405
- 15
- 67
- 107
2
votes
2 answers
Error with duck enumeration for IAsyncEnumerable in System.Interactive.Async
I wonder why this code for IAsyncEnumerable<>
dynamic duckAsyncEnumerable = new int[0].ToAsyncEnumerable();
var duckAsyncEnumerator = duckAsyncEnumerable.GetEnumerator();
raises an exception:
'object' does not contain a definition for…
Weerel
- 23
- 5
1
vote
1 answer
Select n last elements before some condition is met
Is there any dedicated Interactive Extensions method which will produce the last n elements before some condition is encountered?
For instance for the array src, I'd like to get the element 99 plus 2 elements right before it:
var src = new[] { 1, 2,…
Max
- 19,654
- 13
- 84
- 122
0
votes
2 answers
Problems with Let semantics in Linq-to-Objects and Linq-to-XML
Please consider the following sample, consisting of a definition of a nested XElement and a pair of Linq expressions. The first expression, which works as expected, iteratively fetches the first and last XElements at the bottom level by selecting…
Reb.Cabin
- 5,426
- 3
- 35
- 64
-1
votes
2 answers
How to batch an IAsyncEnumerable, enforcing a maximum interval policy between consecutive batches?
I have an asynchronous sequence (stream) of messages that are arriving sometimes numerously and sometimes sporadically, and I would like to process them in batches of 10 messages per batch. I also want to enforce an upper limit to the latency…
Theodor Zoulias
- 34,835
- 7
- 69
- 104