Implemented name for Runnable trait in WebSocket Runnables

This commit is contained in:
Nikhil Shagrithaya 2016-07-23 23:27:31 +05:30
parent 8e79709ed1
commit 8a05e7a413

View file

@ -461,6 +461,8 @@ struct ConnectionEstablishedTask {
}
impl Runnable for ConnectionEstablishedTask {
fn name(&self) -> &'static str { "ConnectionEstablishedTask" }
fn handler(self: Box<Self>) {
let ws = self.address.root();
let global = ws.r().global();
@ -510,6 +512,8 @@ impl Runnable for BufferedAmountTask {
// To be compliant with standards, we need to reset bufferedAmount only when the event loop
// reaches step 1. In our implementation, the bytes will already have been sent on a background
// thread.
fn name(&self) -> &'static str { "BufferedAmountTask" }
fn handler(self: Box<Self>) {
let ws = self.address.root();
@ -526,6 +530,8 @@ struct CloseTask {
}
impl Runnable for CloseTask {
fn name(&self) -> &'static str { "CloseTask" }
fn handler(self: Box<Self>) {
let ws = self.address.root();
let ws = ws.r();
@ -568,6 +574,8 @@ struct MessageReceivedTask {
}
impl Runnable for MessageReceivedTask {
fn name(&self) -> &'static str { "MessageReceivedTask" }
#[allow(unsafe_code)]
fn handler(self: Box<Self>) {
let ws = self.address.root();