Minor typo in documentation. (#28687)
This commit is contained in:
parent
23ea1a4fed
commit
c28fd34b65
1 changed files with 1 additions and 1 deletions
|
|
@ -156,7 +156,7 @@ class FlowDocSpec extends AkkaSpec with CompileOnlySpec {
|
||||||
})
|
})
|
||||||
|
|
||||||
//#flow-mat-combine
|
//#flow-mat-combine
|
||||||
// An source that can be signalled explicitly from the outside
|
// A source that can be signalled explicitly from the outside
|
||||||
val source: Source[Int, Promise[Option[Int]]] = Source.maybe[Int]
|
val source: Source[Int, Promise[Option[Int]]] = Source.maybe[Int]
|
||||||
|
|
||||||
// A flow that internally throttles elements to 1/second, and returns a Cancellable
|
// A flow that internally throttles elements to 1/second, and returns a Cancellable
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue