ktoso

[SILGenThunk.cpp:129](emitDistributedThunkForDecl) VAR THUNK IS:
(accessor_decl implicit <anonymous @ 0x1591115a0> interface type="<ActorSystem where ActorSystem : DistributedActorSystem, ActorSystem.SerializationRequirement == any Decodable & Encodable> (Worker<ActorSystem>) -> () async throws -> String" access=internal final captures=(<generic> ) nonisolated distributed_thunk _distributed_get for="distributedVariable"
  (parameter "self" interface type="Worker<ActorSystem>" known_to_be_local)
  (parameter_list)
  (brace_stmt implicit
    (if_stmt implicit
      (conditions=array
        (call_expr implicit type="Bool" nothrow isolation_crossing="none"
          (declref_expr implicit type="(AnyObject) -> Bool" decl="Distributed.(file).__isRemoteActor" function_ref=single)
          (argument_list implicit

ktoso

Isolation

Notes

that closure will inherits the isolation of the surrounding context by default. Often this is desirable, but if it isn't, there's no way to turn it off2.

Great to acknowlage that! Yes detach is too big of a gun to solve this.

---

ktoso

Proposals related to the Swift Concurrency effort:

• SE-0296: Async/await
• SE-0297: Concurrency Interoperability with Objective-C
• SE-0298: Async/Await: Sequences
• SE-0300: Continuations for interfacing async tasks with synchronous code
• ConcurrentValue and @concurrent closures
• Actors
• Structured concurrency
• [Task Local Values](https://gi

ktoso

Swift (Baggage) Context & (Distributed) Tracing

Big Picture / Open Questions

"Context"

Everyone has context.

This is _Baggage_Context, intended specifically for carrying values over:

ktoso

/// Conform references types for use in the COW wrapper to this protocol
protocol Cowable: class {
  /// Make a new unique instance of `copied`
  static func makeUnique(_ copied: Self) -> Self
}

/// A wrapper that turns a Cowable reference type into a value-semantic
/// type with access to all of its properties
@dynamicMemberLookup

ktoso

[info] Benchmark                                (pool)  (recursion)  (threads)   Mode  Cnt       Score      Error   Units
[info] AndThenBenchmark.improved_post              fjp         8192          1  thrpt   30       2.297 ±    0.053  ops/ms
[info] AndThenBenchmark.improved_post              fix         8192          1  thrpt   30       2.389 ±    0.042  ops/ms
[info] AndThenBenchmark.improved_post              fie         8192          1  thrpt   30       2.884 ±    0.038  ops/ms
[info] AndThenBenchmark.improved_pre               fjp         8192          1  thrpt   30       4.280 ±    0.068  ops/ms
[info] AndThenBenchmark.improved_pre               fix         8192          1  thrpt   30       4.486 ±    0.078  ops/ms
[info] AndThenBenchmark.improved_pre               fie         8192          1  thrpt   30       1.227 ±    0.018  ops/ms
[info] AndThenBenchmark.stdlib_post                fjp         8192          1  thrpt   30       1.678 ±    0.034  ops/ms
[info] AndThenBenchmark.stdlib_post             

ktoso

// auto-generated by sbt-boilerplate
/*
 * Copyright (C) 2015-2018 Lightbend Inc. <https://www.lightbend.com>
 */
package akka.japi.tuple

/**
 * Used to create tuples with 3 elements in Java.
 */
object Tuple3 {

ktoso

[WARN] [01/04/2018 13:44:14.114] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Allocated receiver: Actor[akka://RemoteSystem/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622]
[WARN] [01/04/2018 13:44:14.130] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Created SinkRef, pointing to remote Sink receiver: Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622], local worker: akka.stream.stage.GraphStageLogic$StageActor@2718ee31
[WARN] [01/04/2018 13:44:14.131] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(0,payload-1) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622]
[WARN] [01/04/2018 13:44:14.131] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec

ktoso

[WARN] [01/04/2018 13:44:14.114] [RemoteSystem-akka.test.stream-dispatcher-21] [SinkRefTargetSource$$anon$1(akka://RemoteSystem)] Allocated receiver: Actor[akka://RemoteSystem/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622]
[WARN] [01/04/2018 13:44:14.130] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Created SinkRef, pointing to remote Sink receiver: Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622], local worker: akka.stream.stage.GraphStageLogic$StageActor@2718ee31
[WARN] [01/04/2018 13:44:14.131] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec)] Sending sequenced: SequencedOnNext(0,payload-1) to Actor[akka.tcp://RemoteSystem@localhost:50507/user/remoteActor/StreamSupervisor-1/$$a-SinkRefTargetSource-0#2110155622]
[WARN] [01/04/2018 13:44:14.131] [StreamRefsSpec-akka.test.stream-dispatcher-16] [SinkRef$$anon$2(akka://StreamRefsSpec

ktoso

 /**
   * Returns a Flow.Processor that subscribes to a sequence of Operations and
   * produces a sequence of corresponding Submissions. The Operations must be
   * members of this OperationGroup. Calling Subscription.onNext with any
   * Operation that is not a member of this OperationGroup, that is was not
   * created by calling one of the Operation factory methods on this
   * OperationGroup, will cause the Subscription to be canceled and call
   * Subscriber.onError with IllegalArgumentException. The method
   * Subscription.onNext will call submit on each Operation it is passed and
   * publish the resulting Submission. Since an Operation can only be submitted