| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ActorLazyTest.kt | 15 val actor = actor<String>(start = CoroutineStart.LAZY) { in <lambda>() constant
18 actor as Job // type assertion in <lambda>()
19 assertFalse(actor.isActive) in <lambda>()
20 assertFalse(actor.isCompleted) in <lambda>()
21 assertFalse(actor.isClosedForSend) in <lambda>()
24 assertFalse(actor.isActive) in <lambda>()
25 assertFalse(actor.isCompleted) in <lambda>()
26 assertFalse(actor.isClosedForSend) in <lambda>()
29 actor.start() in <lambda>()
32 assertFalse(actor.isActive) in <lambda>()
[all …]
|
| D | ActorTest.kt | 26 val actor = actor<String>(capacity = capacity) { in <lambda>() constant
29 actor as Job // type assertion in <lambda>()
30 assertTrue(actor.isActive) in <lambda>()
31 assertFalse(actor.isCompleted) in <lambda>()
32 assertFalse(actor.isClosedForSend) in <lambda>()
35 assertFalse(actor.isActive) in <lambda>()
36 assertTrue(actor.isCompleted) in <lambda>()
37 assertTrue(actor.isClosedForSend) in <lambda>()
44 val actor = actor<String>(capacity = capacity) { in <lambda>() constant
49 actor as Job // type assertion in <lambda>()
[all …]
|
| D | DoubleChannelCloseStressTest.kt | 16 … val actor = GlobalScope.actor<Int>(CoroutineName("actor"), start = CoroutineStart.LAZY) { in testDoubleCloseStress() constant
21 actor.send(1) in testDoubleCloseStress()
27 actor.close() in testDoubleCloseStress()
|
| D | ProduceConsumeJvmTest.kt | 49 val actor = actor<Int>(capacity = capacity) { in <lambda>() constant
57 actor.send(i) in <lambda>()
59 actor.close() in <lambda>()
|
| /external/llvm-project/llvm/test/Transforms/Coroutines/ |
| D | coro-async.ll | 6 %async.actor = type { i64 }
9 %async.ctxt = type { i8*, void (i8*, %async.task*, %async.actor*)* }
23 i64 ptrtoint (void (i8*, %async.task*, %async.actor*)* @my_async_function to i64),
31 …er_async_function_fp.apply(i8* %fnPtr, i8* %async.ctxt, %async.task* %task, %async.actor* %actor) {
32 %callee = bitcast i8* %fnPtr to void(i8*, %async.task*, %async.actor*)*
33 tail call swiftcc void %callee(i8* %async.ctxt, %async.task* %task, %async.actor* %actor)
48 define swiftcc void @my_async_function(i8* %async.ctxt, %async.task* %task, %async.actor* %actor) {
73 …%return_to_caller.addr = bitcast void(i8*, %async.task*, %async.actor*)** %callee_context.return_t…
81 %callee = bitcast void(i8*, %async.task*, %async.actor*)* @asyncSuspend to i8*
85 … void (i8*, i8*, %async.task*, %async.actor*)* @my_async_function.my_other_async_function_fp.apply,
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | FailFastOnStartTest.kt | 65 actor<Int>(Dispatchers.Main) { fail() } in <lambda>()
70 val actor = actor<Int>(Dispatchers.Main, start = CoroutineStart.LAZY) { fail() } in <lambda>() constant
71 actor.send(1) in <lambda>()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| D | StatefulActorBenchmark.kt | 82 actor<Letter>(capacity = 1024) { in requestorActor()
89 return@actor in requestorActor()
102 actor<StatefulActorBenchmark.Letter>(capacity = 1024) { in computationActor()
115 is Stop -> return@actor in computationActor()
|
| D | PingPongActorBenchmark.kt | 68 actor<PingPongActorBenchmark.Letter>(capacity = capacity) { in CoroutineScope()
81 return@actor in CoroutineScope()
89 actor<PingPongActorBenchmark.Letter>(capacity = capacity) { in pongActorCoroutine()
95 return@actor in pongActorCoroutine()
|
| D | CycledActorsBenchmark.kt | 69 private fun lastActor(stopChannel: Channel<Unit>) = actor<Letter>(capacity = 1024) { in <lambda>()
84 return@actor in <lambda>()
91 …private fun createActor(nextActor: SendChannel<Letter>, stopChannel: Channel<Unit>) = actor<Letter… in <lambda>()
101 return@actor in <lambda>()
|
| D | ConcurrentStatefulActorBenchmark.kt | 89 actor<Letter>(capacity = 1024) { in requestorActorUnfair()
101 return@actor in requestorActorUnfair()
115 actor<Letter>(capacity = 1024) { in requestorActorFair()
129 return@actor in requestorActorFair()
|
| /external/jackson-databind/src/test/java/com/fasterxml/jackson/databind/deser/filter/ |
| D | ProblemHandlerLocation1440Test.java | 80 public ActivityEntity actor; field in ProblemHandlerLocation1440Test.Activity
86 …public Activity(@JsonProperty("actor") final ActivityEntity actor, @JsonProperty("object") final A… in Activity() argument
87 this.actor = actor; in Activity()
|
| /external/llvm-project/clang/test/AST/ |
| D | attr-swift_attr.m | 3 __attribute__((swift_attr("@actor")))
8 // CHECK-NEXT: SwiftAttrAttr {{.*}} "@actor"
|
| /external/kotlinx.coroutines/ui/ |
| D | coroutines-guide-ui.md | 219 <!--- INCLUDE .*/example-ui-actor-([0-9]+).kt -->
234 > You can get the full code [here](kotlinx-coroutines-javafx/test/guide/example-ui-actor-01.kt).
260 or otherwise ignore a cancellation signal. A better solution is to use an [actor] for tasks that sh…
265 // launch one actor to handle all events on this node
266 val eventActor = GlobalScope.actor<MouseEvent>(Dispatchers.Main) {
269 // install a listener to offer events to this actor
276 > You can get the full code [here](kotlinx-coroutines-javafx/test/guide/example-ui-actor-02.kt).
278 The key idea that underlies an integration of an actor coroutine and a regular event handler is tha…
279 ….offer] function on [SendChannel] that does not wait. It sends an element to the actor immediately,
283 animation is running. This happens because the actor is busy with an animation and does not receive…
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | StackTraceRecoveryChannelsTest.kt | 153 val actor = actor<Int>(job, Channel.UNLIMITED) { in <lambda>() constant
160 actor.offer(1) in <lambda>()
|
| /external/antlr/runtime/ObjC/Framework/ |
| D | TreeRewriter.h | 36 id actor; variable
45 @property (retain) id actor;
|
| D | TreeRewriter.m | 48 actor = anObject;
56 if ( [actor respondsToSelector:ruleSEL] )
57 return [actor performSelector:ruleSEL];
63 @synthesize actor;
|
| D | TreeWizard.h | 49 id actor; variable
60 @property (retain) id actor;
|
| D | TreeWizard.m | 48 actor = anActor;
49 if ( actor ) [actor retain];
63 if ( actor ) [actor release];
74 … if ( [(TreeWizard *)actor _parse:t Pattern:object1/* tpattern */ Map:object2 /* labels */] ) {
79 if ( [(TreeWizard *)actor _parse:t Pattern:object1/* tpattern */ Map:nil] ) {
95 @synthesize actor;
|
| /external/rust/crates/tokio/src/sync/tests/ |
| D | loom_semaphore_batch.rs | 23 async fn actor(shared: Arc<Shared>) { in basic_usage() function
43 block_on(actor(shared)); in basic_usage()
47 block_on(actor(shared)); in basic_usage()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-sync-07.kt | 33 fun CoroutineScope.counterActor() = actor<CounterMsg> { in <lambda>()
|
| /external/python/cpython2/Doc/tools/ |
| D | susp-ignored.csv | 138 library/xml.etree.elementtree,,:actor,"for actor in root.findall('real_person:actor', ns):"
139 library/xml.etree.elementtree,,:name,"name = actor.find('real_person:name', ns)"
140 library/xml.etree.elementtree,,:character,"for char in actor.findall('role:character', ns):"
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/ |
| D | README.md | 12 | [actor][kotlinx.coroutines.channels.actor] | [SendChannel][kotlinx.coroutines.channels.SendCh…
137 …x.coroutines.channels.actor]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/…
139 …b.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.channels/-actor-scope/index.html
|
| /external/python/cpython2/Doc/library/ |
| D | xml.etree.elementtree.rst | 288 <actor>
292 </actor>
293 <actor>
298 </actor>
306 for actor in root.findall('{http://people.example.com}actor'):
307 name = actor.find('{http://people.example.com}name')
309 for char in actor.findall('{http://characters.example.com}character'):
319 for actor in root.findall('real_person:actor', ns):
320 name = actor.find('real_person:name', ns)
322 for char in actor.findall('role:character', ns):
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/test/guide/ |
| D | example-ui-actor-03.kt | 65 …val eventActor = GlobalScope.actor<MouseEvent>(Dispatchers.Main, capacity = Channel.CONFLATED) { /… in onClick()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/akka/ |
| D | PingPongAkkaBenchmark.kt | 7 import akka.actor.*
|