Skip to content

Instantly share code, notes, and snippets.

View nodef0's full-sized avatar

nodef0 nodef0

View GitHub Profile
// Example of merging two async streams of different types into one
// Using websocket's example/async-server.rs as basis
use websocket::message::{Message, OwnedMessage};
use websocket::r#async::Server;
use websocket::server::InvalidConnection;
use futures::{future, Future, Sink, Stream};
use tokio::runtime::TaskExecutor;