wtx 0.44.2

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

use crate::misc::{Lease, LeaseMut};

/// Type that indicates the usage of the `serde_json` dependency.
#[derive(Debug)]
pub struct SerdeJson;

impl Lease<SerdeJson> for SerdeJson {
  #[inline]
  fn lease(&self) -> &SerdeJson {
    self
  }
}

impl LeaseMut<SerdeJson> for SerdeJson {
  #[inline]
  fn lease_mut(&mut self) -> &mut SerdeJson {
    self
  }
}

_impl_se_collections!(
  (SerdeJson, serde::Serialize),
  array: |this, bytes, _drsr| { serde_json::to_writer(bytes, &this[..])?; }
  arrayvector: |this, bytes, _drsr| { serde_json::to_writer(bytes, this)?; }
  slice_ref: |this, bytes, _drsr| { serde_json::to_writer(bytes, this)?; }
  vec: |this, bytes, _drsr| { serde_json::to_writer(bytes, this)?; }
);

#[cfg(all(feature = "client-api-framework", test))]
mod tests {
  _create_dnsn_test!(
    json,
    (VerbatimEncoder, VerbatimDecoder),
    SerdeJson as SerdeJson,
    (r#"{"foo":"foo"}"#, r#"{"bar":"bar"}"#.into()),
    (
      VerbatimEncoder { data: _Foo { foo: "foo" } },
      VerbatimDecoder { data: _Bar { bar: "bar".into() } }
    ),
  );

  _create_dnsn_test!(
    json_rpc,
    (JsonRpcEncoder, JsonRpcDecoder),
    SerdeJson as SerdeJson,
    (
      r#"{"jsonrpc":"2.0","method":"method","params":{"foo":"foo"},"id":0}"#,
      r#"{"jsonrpc":"2.0","method":"method","result":{"bar":"bar"},"id":0}"#.into()
    ),
    (
      JsonRpcEncoder { id: 0, method: "method", params: _Foo { foo: "foo" } },
      JsonRpcDecoder {
        id: 0,
        method: Some("method".try_into().unwrap()),
        result: Ok(_Bar { bar: "bar".into() })
      }
    ),
  );
}