Skip to content

Commit

Permalink
pitchme: update presentation
Browse files Browse the repository at this point in the history
  • Loading branch information
niqdev committed Nov 14, 2017
1 parent 8a7a2cb commit 89202be
Showing 1 changed file with 6 additions and 8 deletions.
14 changes: 6 additions & 8 deletions PITCHME.md
Original file line number Diff line number Diff line change
Expand Up @@ -271,12 +271,12 @@ trait MonitorStream {
}
```

+++

@[1-5]
@[6-7, 15]
@[8-14]

+++

Monitor (part 2)

```scala
Expand Down Expand Up @@ -311,9 +311,8 @@ class EntityActor(monitorActor: ActorRef, ...)(implicit ...)
override def receive: Receive = {
case Migrate =>
CassandraSource(...).async
.via(simple1AsyncFlow).async
.via(simple1AsyncFlow).async
.via(customExecutionContextFlow(...,
.via(simpleAsyncFlow).async
.via(customExecutionContextFlow(
actorSystem.dispatchers
.lookup("application.custom-dispatcher"))
.async
Expand All @@ -323,8 +322,8 @@ class EntityActor(monitorActor: ActorRef, ...)(implicit ...)
}
```

@[1-4, 14-15]
@[5-13]
@[1-4, 13-14]
@[5-12]

+++

Expand Down Expand Up @@ -352,7 +351,6 @@ Resources
- [Datastax](http://docs.datastax.com/en/landing_page/doc/landing_page/docList.html)
- [Akka](https://doc.akka.io/docs/akka/current/scala/index.html)
- [ScalaTest](http://www.scalatest.org)
- [akka-stream-cassandra](https://github.com/niqdev/akka-stream-cassandra)

---

Expand Down

0 comments on commit 89202be

Please sign in to comment.