MCPcopy Create free account

hub / github.com/carllerche/kabuki / functions

Functions24 in github.com/carllerche/kabuki

⨍ Functions 24◇ Types & classes 13
↓ 6 callersMethodcall
(&mut self, req: Self::Request)
src/lib.rs:276
↓ 4 callersMethodpoll
(&mut self)
src/lib.rs:341
↓ 3 callersMethodspawn_fn
Spawn the given closure as an actor
src/lib.rs:238
↓ 1 callersFunctionactor_fn
Returns an `Actor` backed by the given closure.
src/lib.rs:184
↓ 1 callersMethodas_pub
(&self)
src/lib.rs:558
↓ 1 callersMethodclone
(&self)
src/lib.rs:324
↓ 1 callersMethodis_call_ready
(&mut self)
src/lib.rs:457
↓ 1 callersMethodis_running
(&self)
src/lib.rs:551
↓ 1 callersMethodpair
(self, actor: A)
src/lib.rs:247
↓ 1 callersMethodpoll_actor
(&mut self)
src/lib.rs:408
↓ 1 callersMethodpoll_pending
(&mut self)
src/lib.rs:385
↓ 1 callersMethodpoll_ready
Returns `Async::Ready` when the actor can accept a new request
src/lib.rs:291
↓ 1 callersMethodpush_processing
(&mut self, processing: Processing<A>)
src/lib.rs:466
↓ 1 callersMethodremove_processing
(&mut self, idx: usize)
src/lib.rs:485
↓ 1 callersMethodspawn
Spawn a new actor
src/lib.rs:227
Functionactor_ref_is_clone_and_send
()
tests/test_actor.rs:53
Methodfrom
(_: CallError<T>)
src/lib.rs:573
Methodinbox_capacity
Sets the actor's inbox queue capacity. The default value is 1024.
src/lib.rs:212
Methodmax_in_flight
Sets the max number of in-flight requests the actor can process concurrently. The default value is 16
src/lib.rs:221
Functionmultiple_request_response
()
tests/test_actor.rs:29
Methodnew
Returns a new actor `Builder` with default settings
src/lib.rs:202
Methodpoll
Poll the `Actor` to see if it has completed processing. Allows the actor to advance its internal state without receiving a message. For example, if t
src/lib.rs:59
Methodpoll_ready
Indicates that the actor is ready to process the next inbox message Before the `ActorCell` attempts to read a message off the inbox, it will call thi
src/lib.rs:72
Functionsimple_request_response
()
tests/test_actor.rs:13