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

#tweet-source now is bound to the actual impl

Browse source
This commit is contained in:
Paolo Rascuna 2016-03-20 22:43:19 +00:00
parent 063f37d957
commit c61eb62395
1 changed files with 4 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-docs/rst/scala/code/docs/stream/TwitterStreamQuickstartDocSpec.scala
View file

@ -31,7 +31,10 @@ object TwitterStreamQuickstartDocSpec {
val akka = Hashtag("#akka") val akka = Hashtag("#akka")
//#model //#model
val tweets = Source( //#tweet-source
val tweets: Source[Tweet, NotUsed]
//#tweet-source
= Source(
Tweet(Author("rolandkuhn"), System.currentTimeMillis, "#akka rocks!") :: Tweet(Author("rolandkuhn"), System.currentTimeMillis, "#akka rocks!") ::
Tweet(Author("patriknw"), System.currentTimeMillis, "#akka !") :: Tweet(Author("patriknw"), System.currentTimeMillis, "#akka !") ::
Tweet(Author("bantonsson"), System.currentTimeMillis, "#akka !") :: Tweet(Author("bantonsson"), System.currentTimeMillis, "#akka !") ::
@ -53,12 +56,6 @@ class TwitterStreamQuickstartDocSpec extends AkkaSpec {
// Disable println // Disable println
def println(s: Any): Unit = () def println(s: Any): Unit = ()
trait Example0 {
//#tweet-source
val tweets: Source[Tweet, NotUsed]
//#tweet-source
}
trait Example1 { trait Example1 {
//#first-sample //#first-sample
//#materializer-setup //#materializer-setup