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

Add java duration support for Source.tick (Java DSL) #24339 (#24645)

Browse source
This commit is contained in:
Yan Su 2018-03-06 00:13:15 +08:00 • committed by Johannes Rudolph
parent 0ea8c0d872
commit 519e6ae546
4 changed files with 18 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-stream/src/main/scala/akka/stream/javadsl/Source.scala
View file

@ -7,6 +7,7 @@ import java.util
import java.util.Optional
import akka.util.{ ConstantFun, Timeout }
import akka.util.JavaDurationConverters._
import akka.{ Done, NotUsed }
import akka.actor.{ ActorRef, Cancellable, Props }
import akka.event.LoggingAdapter
@ -209,6 +210,12 @@ object Source {
def tick[O](initialDelay: FiniteDuration, interval: FiniteDuration, tick: O): javadsl.Source[O, Cancellable] =
new Source(scaladsl.Source.tick(initialDelay, interval, tick))
/**
* Same as [[tick]], but accepts Java [[java.time.Duration]] instead of Scala ones.
*/
def tick[O](initialDelay: java.time.Duration, interval: java.time.Duration, tick: O): javadsl.Source[O, Cancellable] =
Source.tick(initialDelay.asScala, interval.asScala, tick)
/**
* Create a `Source` with one element.
* Every connected `Sink` of this stream will see an individual stream consisting of one element.