=str #16652 Add java docs for 'Basics and working with Flows'
This commit is contained in:
parent
0a43aa2693
commit
685da0b80a
5 changed files with 220 additions and 4 deletions
|
|
@ -86,7 +86,7 @@ class FlowDocSpec extends AkkaSpec {
|
|||
//#compound-source-is-not-keyed-runWith
|
||||
|
||||
//#compound-source-is-not-keyed-run
|
||||
// retain the materialized map, in order to retrieve the timers Cancellable
|
||||
// retain the materialized map, in order to retrieve the timer's Cancellable
|
||||
val materialized = timerMap.to(Sink.ignore).run()
|
||||
val timerCancellable = materialized.get(timer)
|
||||
timerCancellable.cancel()
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue