actix/actix-extras
1
0
Fork 0
mirror of https://github.com/actix/actix-extras.git synced 2024-12-01 02:44:37 +01:00
Code Issues Releases Wiki Activity

update names

Browse Source
This commit is contained in:
Nikolay Kim 2018-02-12 12:45:08 -08:00
parent 8c1b5fa945
commit 720d8c36c1
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/context.rs
View File

@ -8,7 +8,7 @@ use smallvec::SmallVec;
use actix::{Actor, ActorState, ActorContext, AsyncContext, use actix::{Actor, ActorState, ActorContext, AsyncContext,
Addr, Handler, Message, SpawnHandle, Syn, Unsync}; Addr, Handler, Message, SpawnHandle, Syn, Unsync};
use actix::fut::ActorFuture; use actix::fut::ActorFuture;
use actix::dev::{ContextImpl, ToEnvelope, RemoteEnvelope}; use actix::dev::{ContextImpl, ToEnvelope, SyncEnvelope};
use body::{Body, Binary}; use body::{Body, Binary};
use error::{Error, ErrorInternalServerError}; use error::{Error, ErrorInternalServerError};
@ -210,7 +210,7 @@ impl<A, M, S> ToEnvelope<Syn<A>, M> for HttpContext<A, S>
M: Message + Send + 'static, M::Result: Send, M: Message + Send + 'static, M::Result: Send,
{ {
fn pack(msg: M, tx: Option<Sender<M::Result>>) -> Syn<A> { fn pack(msg: M, tx: Option<Sender<M::Result>>) -> Syn<A> {
Syn::new(Box::new(RemoteEnvelope::envelope(msg, tx))) Syn::new(Box::new(SyncEnvelope::envelope(msg, tx)))
} }
} }

4
src/ws/context.rs
View File

@ -7,7 +7,7 @@ use smallvec::SmallVec;
use actix::{Actor, ActorState, ActorContext, AsyncContext, use actix::{Actor, ActorState, ActorContext, AsyncContext,
Addr, Handler, Message, Syn, Unsync, SpawnHandle}; Addr, Handler, Message, Syn, Unsync, SpawnHandle};
use actix::fut::ActorFuture; use actix::fut::ActorFuture;
use actix::dev::{ContextImpl, ToEnvelope, RemoteEnvelope}; use actix::dev::{ContextImpl, ToEnvelope, SyncEnvelope};
use body::{Body, Binary}; use body::{Body, Binary};
use error::{Error, ErrorInternalServerError}; use error::{Error, ErrorInternalServerError};
@ -222,7 +222,7 @@ impl<A, M, S> ToEnvelope<Syn<A>, M> for WebsocketContext<A, S>
M: Message + Send + 'static, M::Result: Send M: Message + Send + 'static, M::Result: Send
{ {
fn pack(msg: M, tx: Option<Sender<M::Result>>) -> Syn<A> { fn pack(msg: M, tx: Option<Sender<M::Result>>) -> Syn<A> {
Syn::new(Box::new(RemoteEnvelope::envelope(msg, tx))) Syn::new(Box::new(SyncEnvelope::envelope(msg, tx)))
} }
} }