Skip to content

Commit

Permalink
Fix Scan generic types.
Browse files Browse the repository at this point in the history
  • Loading branch information
bartdesmet committed Feb 13, 2019
1 parent 2582c7c commit e3080a1
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ public static IAsyncEnumerable<TAccumulate> Scan<TSource, TAccumulate>(this IAsy
#if USE_ASYNC_ITERATOR
return AsyncEnumerable.Create(Core);

async IAsyncEnumerator<TSource> Core(CancellationToken cancellationToken)
async IAsyncEnumerator<TAccumulate> Core(CancellationToken cancellationToken)
{
TAccumulate res = seed;

Expand Down Expand Up @@ -155,7 +155,7 @@ public static IAsyncEnumerable<TAccumulate> Scan<TSource, TAccumulate>(this IAsy
#if USE_ASYNC_ITERATOR
return AsyncEnumerable.Create(Core);

async IAsyncEnumerator<TSource> Core(CancellationToken cancellationToken)
async IAsyncEnumerator<TAccumulate> Core(CancellationToken cancellationToken)
{
TAccumulate res = seed;

Expand All @@ -182,7 +182,7 @@ public static IAsyncEnumerable<TAccumulate> Scan<TSource, TAccumulate>(this IAsy
#if USE_ASYNC_ITERATOR
return AsyncEnumerable.Create(Core);

async IAsyncEnumerator<TSource> Core(CancellationToken cancellationToken)
async IAsyncEnumerator<TAccumulate> Core(CancellationToken cancellationToken)
{
TAccumulate res = seed;

Expand Down

0 comments on commit e3080a1

Please sign in to comment.