diff --git a/Cargo.toml b/Cargo.toml
index c8ee816..b053905 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -28,4 +28,4 @@ futures = "0.3.5"
 tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
 futures-retry = "0.6"
 pin-utils = "0.1"
-rocket = "0.5.0-rc.1"
+rocket = "0.5.0-rc.3"
diff --git a/examples/server.rs b/examples/server.rs
index 278be94..2688a60 100644
--- a/examples/server.rs
+++ b/examples/server.rs
@@ -1,7 +1,7 @@
 use rocket::http::Status;
 use rocket::request::Outcome;
 use rocket::request::Request;
-use rocket::response::content::Html;
+use rocket::response::content::RawHtml;
 use rocket::response::stream::{Event, EventStream};
 use rocket::tokio::time::{self, Duration};
 use rocket::{get, launch, routes};
@@ -46,8 +46,8 @@ fn events(id: LastEventId) -> EventStream![] {
 }
 
 #[get("/")]
-fn index() -> Html<&'static str> {
-    Html(
+fn index() -> RawHtml<&'static str> {
+    RawHtml(
         r#"
 Open Console
 <script>
diff --git a/src/event_source.rs b/src/event_source.rs
index 179f0d2..f283963 100644
--- a/src/event_source.rs
+++ b/src/event_source.rs
@@ -3,8 +3,16 @@ use crate::retry::{RetryPolicy, DEFAULT_RETRY};
 use core::pin::Pin;
 use eventsource_stream::Eventsource;
 pub use eventsource_stream::{Event as MessageEvent, EventStreamError};
-use futures_core::future::{BoxFuture, Future};
-use futures_core::stream::{BoxStream, Stream};
+#[cfg(not(target_arch = "wasm32"))]
+use futures_core::future::BoxFuture;
+use futures_core::future::Future;
+#[cfg(target_arch = "wasm32")]
+use futures_core::future::LocalBoxFuture;
+#[cfg(not(target_arch = "wasm32"))]
+use futures_core::stream::BoxStream;
+#[cfg(target_arch = "wasm32")]
+use futures_core::stream::LocalBoxStream;
+use futures_core::stream::Stream;
 use futures_core::task::{Context, Poll};
 use futures_timer::Delay;
 use pin_project_lite::pin_project;
@@ -12,8 +20,16 @@ use reqwest::header::{HeaderName, HeaderValue};
 use reqwest::{Error as ReqwestError, IntoUrl, RequestBuilder, Response, StatusCode};
 use std::time::Duration;
 
+#[cfg(not(target_arch = "wasm32"))]
 type ResponseFuture = BoxFuture<'static, Result<Response, ReqwestError>>;
+#[cfg(target_arch = "wasm32")]
+type ResponseFuture = LocalBoxFuture<'static, Result<Response, ReqwestError>>;
+
+#[cfg(not(target_arch = "wasm32"))]
 type EventStream = BoxStream<'static, Result<MessageEvent, EventStreamError<ReqwestError>>>;
+#[cfg(target_arch = "wasm32")]
+type EventStream = LocalBoxStream<'static, Result<MessageEvent, EventStreamError<ReqwestError>>>;
+
 type BoxedRetry = Box<dyn RetryPolicy + Send + Unpin + 'static>;
 
 /// The ready state of an [`EventSource`]