the reason to do so, is to decouple all the data that we're currently passing around, which, in my youthful zeal, i have, wrongly bundled into a single struct
there's a database connection, a worker mutex, and a search index ref. (among others
my thought was that Searcher would lend itself to easily extract into an actor, but it is, itself deeply bundled with two other datastructures, one of them, the post struct, and the other the database connection, because the post struct doesn't hold all data, that Searcher stores about a page
but, if the
Sender isn't part of the ActorSystem i need to pass around a ref, just like with the database connection, and, in my naïvité, i thought i could avoid that, but knowing the actor's name
and that's just the three actors I've identified so far
i haven't looked into how we compute notifications yes, cuz i was afraid of what I'd find, lol
Hi all! looking for some inspiration :) ... I'm trying to store references to different kinds of entities in a HashMap, since I can not put different ActorRef together because they are generic over the message type I figured I can do a HashMap of BasicActorRef but I'd like to go back to ActorRef from BasicActorRef later on, is it possible? I see there is a
typed function but needs an ExtendedCell as parameter, no idea where to get that, looks like an internal type
@olanod - I had a similar requirement - I just use BasicActorRef and use try_tell - the gotcha is looking out for issue #129. There is a work around there where you just need to be explicit when you send your message type in.
@here - Is there any documentation around how to explicitly manage child actors? I have a scenario where I want to shut down a child actor once its done. Looking at Context.shutdown() or explicitly using a Stop message. Akka has a PoisonPill which would kill the actor once it hit that message in the mailbox. Anything similar? And what are the rules when ActorTerminated system message is sent to the parent? Is this before or after the child is shutdown and removed from the children list?
Hi. are there any examples out there on how to send a message to an actor, and, await it’s response (perhaps, something similar to the one on actix with it’s Ping). I guess if i’m sending a message from an actor, i could include it’s address in the send, and, message a response back. But, what if i’m sending it from
main etc?
oh..i guess i’d use the
ask pattern
if i send a message between two actors (say, add 2 + 2) - in order to handle the response (assuming, i do a send back from the compute actor to the asking actor), would my message necessarily also need to include a id of sorts? Wondering what would happen if i send two messages (2,2) and (3,3) one after the other? would the responses be sent back in order? thanks
@georgemp I haven't confirmed it yet(and perhaps you did already?) but my assumption is that because messages arrive to the letter inbox in order because you send them in order from the same place and from there are handed one by one to the handler, on the way back the same should happen and you would get things in order unless you do some async stuff when processing the messages
@olanod - did you ever find a way to run a future to completion from within an actor's recv method? Just using block_on results in the error
cannot execute
LocalPoolexecutor from within another executor: EnterError
and trying to use the ctx.run() method complains about a lifetime issue as the future that I'm trying to execute is a method on an S3 bucket client from rusoto. Thanks!
Never mind, was implementing it incorrectly. The docs work as expected. The key was using the
move keyword
For anyone else that has this issue, which is generally described as trying to use the Riker actor system within another runtime, you do need the top-level runtime to execute futures. So, when using the Tokio runtime, I needed to get a handle to it via
tokio::runtime::Handle::current() and then pass this handle around to the actor system whenever an actor needed to be able to block on a future. Hope this helps others! I think this should be added to the docs, and if I get motivated I may submit a PR for this.
Hello! I'm trying to make a web game using websocket and riker, but I can barely find any resources about how to connect them (e.g. feeding websocket messages into actors, using tokio runtime with riker because some of websocket crates depend on it). Has anybody tried to use websocket with riker?
3 replies
Can someone with merge rights take a look into riker-rs/riker#145 request. Github actions much better then travis. Travis has contant problems and slow.
Version 0.4.2 is now available. Special thanks to @olexiyb and @nothingismagick for:
- Updated to use stable dashmap
- Fixed clippy and pre-commit errors
- Migration from Travis to GitHub Actions
Next up we'll be expanding on the migration to GHA to improve cadence with regards to code merges and version releases. Thank you to the team and community.
[dependencies]
riker = "0.4.2"
we are working on using libp2p-noise (XX flavor handshake) for remote actors (sort of like the
ask pattern here: https://riker.rs/patterns/ )
Does anyone know what to do about
'there is no timer running, must be called from the context of Tokio runtime' when using Context::run? riker-rs/riker#150
[tokio::main]
async fn main() -> std::io::Result<()> {let rt = tokio::runtime::Handle::current() ;
let sys = ActorSystem::new().unwrap(); // how do i add rt to the sys handle
Does anybody have a suggestion for how to access to an actor from a future spawned with
Context::run? I would basically like to use self when running a future using ctx.run(async move { self.data = something().await; }) but of course that doesn't work. Can I use messages?
