akka-learn's People
akka-learn's Issues
Persistent Actor
As in Eventsourced.scala
final private[akka] def internalPersist[A](event: A)(handler: A ⇒ Unit): Unit = {
if (recoveryRunning) throw new IllegalStateException("Cannot persist during replay. Events can be persisted when receiving RecoveryCompleted or later.")
pendingStashingPersistInvocations += 1
pendingInvocations addLast StashingHandlerInvocation(event, handler.asInstanceOf[Any ⇒ Unit])
eventBatch ::= AtomicWrite(PersistentRepr(event, persistenceId = persistenceId,
sequenceNr = nextSequenceNr(), writerUuid = writerUuid, sender = sender()))
}
final private[akka] def internalPersistAsync[A](event: A)(handler: A ⇒ Unit): Unit = {
if (recoveryRunning) throw new IllegalStateException("Cannot persist during replay. Events can be persisted when receiving RecoveryCompleted or later.")
pendingInvocations addLast AsyncHandlerInvocation(event, handler.asInstanceOf[Any ⇒ Unit])
eventBatch ::= AtomicWrite(PersistentRepr(event, persistenceId = persistenceId,
sequenceNr = nextSequenceNr(), writerUuid = writerUuid, sender = sender()))
}
final private[akka] def internalDeferAsync[A](event: A)(handler: A ⇒ Unit): Unit = {
if (recoveryRunning) throw new IllegalStateException("Cannot persist during replay. Events can be persisted when receiving RecoveryCompleted or later.")
if (pendingInvocations.isEmpty) {
handler(event)
} else {
pendingInvocations addLast AsyncHandlerInvocation(event, handler.asInstanceOf[Any ⇒ Unit])
eventBatch = NonPersistentRepr(event, sender()) :: eventBatch
}
}
The difference is:
- persist() vs. persistAsync(): increments pendingStashingInvocations += 1
- persistAsync() vs. deferAsync(): deferAsync() only executes handler, that's it
- ( pendingStashingInvocations is irrelevant )
Type signature of source
Flow sink signatures in different articles?
Easy environment setup
download zip -> gist? for each module
git clone -> just run ... better if no cascading (i.e. root directory = each module root) -> gist
gist <-> sub directory sync up?? (.gitignore -> .git in sub dirs?)
Article for lesson 1
*build.sbt
- git clone
- runMain
- run from mobile??? -> separate issue?
BackOff Supervisor
Break down to multiple issues / articles
Cluster
Break down to multiple issues / articles
For my learning ... as there are several Cluster Github issues I want to contribute
Persistent Actor
Break down to multiple issues / articles
Circuit Breaker
Break down to multiple issues / articles
Terminologies revisited
Source sink flow
Steam element graph...
Illustration and cose
sbtopts and sbtconfig ... debug config
sbtopts -> linux
sbtconfig.txt -> windows
Graph Stage in detail
akka Issue 20288, PR 20367, PR 20386 migration guide
Easy run on mobile
scalaFiddle
run button
EASY TO RUN FROM MOBILE!!
Akka 21736 persistent actor
Stream error handling
akka 15710
While processing a stream there are essentially three classes of failure that we should distinguish:
- exceptions from user code
- exceptions from stream handling infrastructure (a.k.a. bugs)
- fatal JVM signals
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.