Aaronontheweb on dev
Convert to ImmutableHashSet for… (compare)
12:47:29 INFO [ClusterSingletonManager, 6] Previous oldest removed [akka.tcp://xxx@localhost:4888]
12:47:29 INFO [ClusterSingletonManager, 6] Younger observed OldestChanged: [ -> myself]
12:47:29 INFO [ClusterSingletonManager, 6] Singleton manager started singleton actor [akka://xxx]
12:47:29 INFO [ClusterSingletonManager, 6] ClusterSingletonManager state change [Younger -> Oldest] Akka.Cluster.Tools.Singleton.YoungerData
12:47:29 INFO [0, Culture=neutral, PublicKeyToken=null]], 9] Getting server list...
12:47:30 ERROR [OneForOneStrategy, 11] Object reference not set to an instance of an object. Object reference not set to an instance of an object.
let stream mat =
Source...
|> Source.viaMat (KillSwitches.Single()) Keep.both
|> Source...
|> Source.``to`` Sink.ignore
|> Graph.run mat
let props (mat: IMaterializer) : Props =
props(
let rec loop (streamKillSwitch: IKillSwitch) (msg: obj) =
match msg with
| LifecycleEvent PostStop ->
streamKillSwitch.Shutdown()
ignored()
| _ -> unhandled()
fun (ctx: Actor<obj>) ->
let taskQueue, streamKillSwitch = stream mat
spawn ctx "another-actor" (Another.props taskQueue) |> ignore
become (loop streamKillSwitch)
).ToProps()
```
custom-dispatcher-300 {
type = Dispatcher
throughput = 300
}
custom-dispatcher-400 {
type = Dispatcher
throughput = 400
}
custom-dispatcher-500 {
type = Dispatcher
throughput = 500
}
```