websocket-util 0.2.0

A crate providing an easy to consume streaming interface for WebSocket data.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

// Copyright (C) 2019-2020 Daniel Mueller <deso@posteo.net>
// SPDX-License-Identifier: GPL-3.0-or-later

use std::future::Future;
use std::net::SocketAddr;

use futures::FutureExt;

use tokio::net::TcpListener;
use tokio::net::TcpStream;
use tokio::spawn;

use tungstenite::accept_async as accept_websocket;
use tungstenite::tokio::TokioAdapter;
use tungstenite::tungstenite::Error as WebSocketError;
use tungstenite::WebSocketStream as WsStream;


/// The WebSocket stream type we use in the server.
pub type WebSocketStream = WsStream<TokioAdapter<TcpStream>>;


/// Create a WebSocket server that handles a customizable set of
/// requests and exits.
pub async fn mock_server<F, R>(f: F) -> SocketAddr
where
  F: FnOnce(WebSocketStream) -> R + Send + Sync + 'static,
  R: Future<Output = Result<(), WebSocketError>> + Send + Sync + 'static,
{
  let mut listener = TcpListener::bind("127.0.0.1:0").await.unwrap();
  let addr = listener.local_addr().unwrap();

  let future = async move {
    listener
      .accept()
      .map(move |result| result.unwrap())
      .then(|(stream, _addr)| accept_websocket(TokioAdapter(stream)))
      .map(move |result| result.unwrap())
      .then(move |ws_stream| f(ws_stream))
      .await
  };

  let _ = spawn(future);
  addr
}