raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Merge pull request #19918 from savulchik/fix-typos

Browse source 
=doc Fix typos in FlowDocTest & FlowDocSpec
This commit is contained in:
Martynas Mickevičius 2016-03-02 15:06:52 +01:00
commit 1029f093bf
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-docs/rst/java/code/docs/stream/FlowDocTest.java
View file

@ -246,7 +246,7 @@ public class FlowDocTest extends AbstractJavaTest {
CompletableFuture<Optional<Integer>> r5 = flow.to(sink).runWith(source, mat); CompletableFuture<Optional<Integer>> r5 = flow.to(sink).runWith(source, mat);
Pair<CompletableFuture<Optional<Integer>>, CompletionStage<Integer>> r6 = flow.runWith(source, sink, mat); Pair<CompletableFuture<Optional<Integer>>, CompletionStage<Integer>> r6 = flow.runWith(source, sink, mat);
// Using more complext combinations // Using more complex combinations
RunnableGraph<Pair<CompletableFuture<Optional<Integer>>, Cancellable>> r7 = RunnableGraph<Pair<CompletableFuture<Optional<Integer>>, Cancellable>> r7 =
source.viaMat(flow, Keep.both()).to(sink); source.viaMat(flow, Keep.both()).to(sink);

2
akka-docs/rst/scala/code/docs/stream/FlowDocSpec.scala
View file

@ -181,7 +181,7 @@ class FlowDocSpec extends AkkaSpec {
val r5: Promise[Option[Int]] = flow.to(sink).runWith(source) val r5: Promise[Option[Int]] = flow.to(sink).runWith(source)
val r6: (Promise[Option[Int]], Future[Int]) = flow.runWith(source, sink) val r6: (Promise[Option[Int]], Future[Int]) = flow.runWith(source, sink)
// Using more complext combinations // Using more complex combinations
val r7: RunnableGraph[(Promise[Option[Int]], Cancellable)] = val r7: RunnableGraph[(Promise[Option[Int]], Cancellable)] =
source.viaMat(flow)(Keep.both).to(sink) source.viaMat(flow)(Keep.both).to(sink)