Hi. I am currently in the process of writing an application that utilizes Actix. I have a
futures::mpsc channel that I use to communicate with another thread, and I’d like to have an Actix actor handle the receiver side of it.
I have registered the receiver as a stream with the actor using
add_stream and provided a corresponding
StreamHandler implementation and everything compiles, but when I actually try to send messages on the channel the
send-call errors with the message “
send failed because receiver is gone”. This appears to indicate that the receiver is dropped somewhere, but I don’t see where that would happen.
I’m quite new to Rust and non-single-threaded programming, so I apologize if I made a general error here, but I really can’t see it.