Hi, probably a dumb question but I'm trying to get a good understanding. I roughly followed the example here: https://docs.rs/awc/0.3.0-alpha.1/awc/
I'm getting ^ the trait std::future::Future is not implemented for awc::sender::SendClientRequest.
What am I doing wrong?
@fafhrd91 Hmmm... But that seems to imply I need one ws client to send messages, and one actix Actor to receive them (so having two websocket connections, even though the websockets protocol is bidirectional) per rust binary to create the connection. Can't I connect directly two actix Actors using the ws::WebsocketContext?
If you're looking for a ready to go solution, I don't know whether that exists
targeting 2.0.0-alpha.1 is fine, however.
I just mapped over a 15k element vector and ran an actic awc client for each value, and killed the server ;) I really want instead to set up a resource that throttles the number of "in progress" requests to some maximum number. I guess a semaphore-like thing? Is there example code for that which I can learn from?
If I have an actor
struct A { b: Addr<B> } and an actor struct B { recipient: Recipient<SomeMsg> } where the recipient is actually A, are the references between these two actors strong? In other words, If I have struct C { a: Addr<A> } that gets dropped, would the cyclical reference prevent A and B from shutting down?
i'm having trouble getting
#[actix_rt::main] to resolve
the cookie value is also removed on browser refresh regardless so setting the expires field doesn't seem to matter anyway
.wrap_fn(|req, srv| {
srv.call(req).map(|mut res: ServiceResponse| {
for mut res_cookie in res.response_mut().cookies() {
if res_cookie.name().eq_ignore_ascii_case("auth") {
res_cookie.make_permanent();
}
}
res
})
})
identity cookie can now be persistent across browser refreshes
Hi I'm trying to implement a blanket implementation for all actors that can handle a specified message.
like this
use actix::prelude::*;
pub mod messages {
use actix::prelude::*;
pub enum TCCMessage<T: 'static> {
Try(T),
Confirm(T),
Cancel(T)
}
impl <T> Message for TCCMessage<T> {
type Result = Result<(), crate::errors::TCCError>;
}
}
pub trait TCCActor {}
impl<A> TCCActor for A
where A: Handler<messages::TCCMessage<dyn std::any::Any + Sized>, Context = Context<A>, Result = Result<(), crate::errors::TCCError>> + Actor
{}so that i can do
pub struct TCCCoodinatorActor {
actors: Vec<Addr<dyn TCCActor>>
}but the compiler complains about messages::TCCMessage<dyn std::any::Any + Sized + 'static> with "only auto traits can be used as additional traits in a trait object". Is there any walkaround?
@fafhrd91 Hello, can you update actix-files, please?
Compiling actix-files v0.2.0-alpha.1
error[E0432]: unresolved imports `actix_service::boxed::BoxedNewService`, `actix_service::boxed::BoxedService`
--> D:\rust\.cargo\registry\src\github.com-1ecc6299db9ec823\actix-files-0.2.0-alpha.1\src/lib.rs:15:34
|
15 | use actix_service::boxed::{self, BoxedNewService, BoxedService};
| ^^^^^^^^^^^^^^^ ^^^^^^^^^^^^ no `BoxedService` in `boxed`
| |
| no `BoxedNewService` in `boxed`
help: a similar name exists in the module
|
15 | use actix_service::boxed::{self, BoxService, BoxedService};
| ^^^^^^^^^^
help: a similar name exists in the module
|
15 | use actix_service::boxed::{self, BoxedNewService, BoxService};
| ^^^^^^^^^^
error[E0053]: method `new_service` has an incompatible type for trait
--> D:\rust\.cargo\registry\src\github.com-1ecc6299db9ec823\actix-files-0.2.0-alpha.1\src/lib.rs:418:5
|
418 | fn new_service(&self, _: &()) -> Self::Future {
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected (), found &()
|
= note: expected type `fn(&Files, ()) -> std::pin::Pin<std::boxed::Box<(dyn core::future::future::Future<Output = std::result::Result<FilesService, ()>> + 'static)>>`
found type `fn(&Files, &()) -> std::pin::Pin<std::boxed::Box<(dyn core::future::future::Future<Output = std::result::Result<FilesService, ()>> + 'static)>>`
error[E0308]: mismatched types
--> D:\rust\.cargo\registry\src\github.com-1ecc6299db9ec823\actix-files-0.2.0-alpha.1\src/lib.rs:100:17
|
100 | / web::block(move || {
101 | | let max_bytes: usize;
102 | | max_bytes = cmp::min(size.saturating_sub(counter), 65_536) as usize;
103 | | let mut buf = Vec::with_capacity(max_bytes);
... |
111 | | })
112 | | .boxed_local(),
| |______________________________^ expected enum `std::result::Result`, found tuple
|
= note: expected type `std::pin::Pin<std::boxed::Box<dyn core::future::future::Future<Output = std::result::Result<std::result::Result<(std::fs::File, bytes::bytes::Bytes), std::io::Error>, futures_channel::oneshot::Canceled>>>>`
found type `std::pin::Pin<std::boxed::Box<dyn core::future::future::Future<Output = std::result::Result<(std::fs::File, bytes::bytes::Bytes), actix_threadpool::BlockingError<_>>>>>`
error: aborting due to 3 previous errors
^
I'm experiencing similar errors with the
I'm experiencing similar errors with the
actix-utils: Compiling actix-utils v0.5.0-alpha1
error[E0053]: method `new_service` has an incompatible type for trait
--> /Users/someonetoignore/.cargo/registry/src/github.com-1ecc6299db9ec823/actix-utils-0.5.0-alpha1/src/either.rs:95:5
|
95 | fn new_service(&self, cfg: &A::Config) -> Self::Future {
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected associated type, found reference
|
= note: expected type `fn(&either::Either<A, B>, <A as actix_service::ServiceFactory>::Config) -> either::EitherNewService<A, B>`
found type `fn(&either::Either<A, B>, &<A as actix_service::ServiceFactory>::Config) -> either::EitherNewService<A, B>`
= note: consider constraining the associated type `<A as actix_service::ServiceFactory>::Config` to `&<A as actix_service::ServiceFactory>::Config` or calling a method that returns `<A as actix_service::ServiceFactory>::Config`
= note: for more information, visit https://doc.rust-lang.org/book/ch19-03-advanced-traits.html
error[E0053]: method `new_service` has an incompatible type for trait
--> /Users/someonetoignore/.cargo/registry/src/github.com-1ecc6299db9ec823/actix-utils-0.5.0-alpha1/src/keepalive.rs:61:5
|
61 | fn new_service(&self, _: &()) -> Self::Future {
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected (), found &()
|
= note: expected type `fn(&keepalive::KeepAlive<R, E, F>, ()) -> futures_util::future::ready::Ready<std::result::Result<keepalive::KeepAliveService<R, E, F>, std::convert::Infallible>>`
found type `fn(&keepalive::KeepAlive<R, E, F>, &()) -> futures_util::future::ready::Ready<std::result::Result<keepalive::KeepAliveService<R, E, F>, std::convert::Infallible>>`
error[E0053]: method `new_service` has an incompatible type for trait
--> /Users/someonetoignore/.cargo/registry/src/github.com-1ecc6299db9ec823/actix-utils-0.5.0-alpha1/src/time.rs:54:5
|
54 | fn new_service(&self, _: &()) -> Self::Future {
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ expected (), found &()
|
= note: expected type `fn(&time::LowResTime, ()) -> futures_util::future::ready::Ready<std::result::Result<time::LowResTimeService, std::convert::Infallible>>`
found type `fn(&time::LowResTime, &()) -> futures_util::future::ready::Ready<std::result::Result<time::LowResTimeService, std::convert::Infallible>>`
error[E0308]: mismatched types
--> /Users/someonetoignore/.cargo/registry/src/github.com-1ecc6299db9ec823/actix-utils-0.5.0-alpha1/src/either.rs:99:45
|
99 | left_fut: self.left.new_service(cfg),
| ^^^ expected associated type, found reference
|
= note: expected type `<A as actix_service::ServiceFactory>::Config`
found type `&<A as actix_service::ServiceFactory>::Config`
= note: consider constraining the associated type `<A as actix_service::ServiceFactory>::Config` to `&<A as actix_service::ServiceFactory>::Config` or calling a method that returns `<A as actix_service::ServiceFactory>::Config`
= note: for more information, visit https://doc.rust-lang.org/book/ch19-03-advanced-traits.html
error[E0308]: mismatched types
--> /Users/someonetoignore/.cargo/registry/src/github.com-1ecc6299db9ec823/actix-utils-0.5.0-alpha1/src/either.rs:100:47
|
100 | right_fut: self.right.new_service(cfg),
| ^^^ expected associated type, found reference
|
= note: expected type `<A as actix_service::ServiceFactory>::Config`
found type `&<A as actix_service::ServiceFactory>::Config`
= note: consider constraining the associated type `<A as actix_service::ServiceFactory>::Config` to `&<A as actix_service::ServiceFactory>::Config` or calling a method that returns `<A as actix_service::ServiceFactory>::Config`
= note: for more information, visit https://doc.rust-lang.org/book/ch19-03-advanced-traits.html
error: aborting due to 5 previous errors
Hi @fafhrd91 , I think my error is caused by the actix-multipart of version 0.2.0-alpha1 is using actix-utils of version 0.5.0-alpha1
I see that the actix-multipart master branch contains newer actix-utils, so sounds like another actix-multipart release would be enought to fix the issue.
I see that the actix-multipart master branch contains newer actix-utils, so sounds like another actix-multipart release would be enought to fix the issue.
i'm trying to pass a json with a list that has a list
but i'm getting this error :
'called
Result::unwrap() on an Err value: Error("expected , or ]", line: 1, column: 64)'
With only 1 element in the second list work fine
Hello. I have been working with Actix for about a week now. From what I understand one arbiter is equal to one thread and one event loop. But with my current code that I am working with, when one arbiter is running a long executing function, it is blocking the other arbiter. I have an example of this behavior in the following github.
https://github.com/babinc/actix_testing
From the github example the AppActor is inside an AppArbiter. When the long_executing_stuff function from the AppActor is called the UiArbiter and UiActor is blocked. I was hoping that the UiActor and Arbiter would keep executing. Is there an easy way to get the functionality that I am desiring? In the real application that I am working with the UiArbiter is running tui-rs.
Thank you
trying to GetValue something from a thread that's working (or sleeping) in a non-blocking way isn't going to work. you'd need something in the middle that holds the value where you can ask for it from the UI and update it from the blocking thread once that's done
Hi all, I'm trying to send an HTTP request with multipart, where the content is a file compressed with
gzip. I'm using as an example the actix server as defined here https://github.com/actix/examples/blob/master/multipart/src/main.rs, and the curl request that I use (after gzip example.txt -> example.txt.gz) is curl -X POST -H "Content-Type: multipart/related" -H "Content-Encoding: gzip" --form "data=@example.txt.gz" http://localhost:8080 (where I set the "Content-Encoding" header). According to the documentation I found here https://actix.rs/docs/request/, actix should automatically decompress the payload according to the header value. But it doesn't seem to work as the uploaded file is still gzipped. Does this decoding apply to multipart fields? How can I decode my multipart?