wtx 0.51.1

A collection of different transport implementations and related tools focused primarily on web technologies.
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

use crate::net::{StreamReader, StreamWriter};

/// A stream of values produced asynchronously.
pub trait Stream: StreamReader + StreamWriter {
  /// Connects the reader and the writer.
  type BridgeOwned;
  /// See [`StreamReader`].
  type ReadHalfOwned: StreamReader;
  /// See [`StreamWriter`].
  type WriteHalfOwned: StreamWriter;

  /// Splits this instance into owned parts that can be used in concurrent scenarios.
  fn into_split(
    self,
  ) -> crate::Result<(Self::BridgeOwned, Self::ReadHalfOwned, Self::WriteHalfOwned)>;
}

impl Stream for () {
  type BridgeOwned = ();
  type ReadHalfOwned = ();
  type WriteHalfOwned = ();

  #[inline]
  fn into_split(
    self,
  ) -> crate::Result<(Self::BridgeOwned, Self::ReadHalfOwned, Self::WriteHalfOwned)> {
    Ok(((), (), ()))
  }
}