wtx 0.45.0

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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

use crate::{
  codec::{CodecController, Decode},
  database::{Database, DatabaseError, ValueIdent},
};
use core::any::type_name;

/// A collection of values.
pub trait Record<'exec>: Sized {
  /// See [Database].
  type Database: Database;

  /// Tries to retrieve and decode a value.
  #[inline]
  fn decode<CI, D>(&self, ci: CI) -> Result<D, <Self::Database as CodecController>::Error>
  where
    CI: ValueIdent<Self>,
    D: Decode<'exec, Self::Database>,
  {
    let mut dw = self.value(ci).ok_or_else(|| {
      DatabaseError::MissingFieldDataInDecoding(
        type_name::<D>().into(),
        ci.idx(self).map(|el| u8::try_from(el).unwrap_or(u8::MAX)),
      )
      .into()
    })?;
    D::decode(&mut dw)
  }

  /// Tries to retrieve and decode an optional value.
  #[inline]
  fn decode_opt<CI, D>(
    &self,
    ci: CI,
  ) -> Result<Option<D>, <Self::Database as CodecController>::Error>
  where
    CI: ValueIdent<Self>,
    D: Decode<'exec, Self::Database>,
  {
    match self.value(ci) {
      Some(mut elem) => Ok(Some(D::decode(&mut elem)?)),
      None => Ok(None),
    }
  }

  /// The number of values.
  fn len(&self) -> usize;

  /// Tries to retrieve a value.
  fn value<CI>(
    &self,
    ci: CI,
  ) -> Option<<Self::Database as CodecController>::DecodeWrapper<'exec, '_, '_>>
  where
    CI: ValueIdent<Self>;

  /// Iterates over all values
  #[inline]
  fn values<'this>(
    &'this self,
  ) -> impl Iterator<
    Item = Option<<Self::Database as CodecController>::DecodeWrapper<'exec, 'this, 'this>>,
  >
  where
    'exec: 'this,
  {
    (0..self.len()).map(|idx| self.value(idx))
  }
}

impl Record<'_> for () {
  type Database = ();

  #[inline]
  fn len(&self) -> usize {
    0
  }

  #[inline]
  fn value<CI>(
    &self,
    _: CI,
  ) -> Option<<Self::Database as CodecController>::DecodeWrapper<'_, '_, '_>>
  where
    CI: ValueIdent<Self>,
  {
    None
  }
}