Skip to content

Conversation

Horusiath
Copy link
Contributor

Changed Akka.Stream DSL naming conventions to closer match LINQ/RxNet:

  • Map -> Select
  • MapAsync -> SelectAsync
  • MapAsyncUnordered -> SelectAsyncUnordered
  • Filter -> Where
  • FilterNot -> WhereNot
  • DropWhile -> SkipWhile
  • Drop -> Skip
  • DropWithin -> SkipWithin
  • MapConcat -> SelectMany
  • Fold -> Aggregate
  • Reduce -> Sum
  • FlatMapConcat -> ConcatMany
  • FlatMapMerge -> MergeMany
  • Future -> Task

@@ -187,7 +187,7 @@ public void Conflate_must_work_with_a_buffer_and_fold()
Source.From(Enumerable.Range(1, 50))
.ConflateWithSeed(i => i, (sum, i) => sum + i)
.Buffer(50, OverflowStrategy.Backpressure)
.RunFold(0, (sum, i) => sum + i, Materializer);
.RunAggregate(0, (sum, i) => sum + i, Materializer);
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Method name should be Conflate_must_work_with_a_buffer_and_aggregate


[Fact]
public void A_Reduce_must_work_when_using_Source_RunReduce()
public void A_Sum_must_work_when_using_Source_RunReduce()
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Should be A_Sum_must_work_when_using_Source_RunSum

@marcpiechura
Copy link
Contributor

Maybe it would make sense to keep the corresponding jvm file name as comment in renamed test files?

@Horusiath
Copy link
Contributor Author

Yes it would make sense.

@Horusiath
Copy link
Contributor Author

@Silv3rcircl3 updated

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants