🥮 mooncakes.io
    Sign in

    moonbit-community/rtc/transport does not have a README file

    AddressError

    source
    pub(all) suberror AddressError {
      InvalidIpv6Length(Int)
      InvalidAddress(String)
    } derive(Eq, 
    Debug    )

    TimeError

    source
    pub(all) suberror TimeError {
      NegativeMonotonicTime(Int64)
      NegativeDuration(Int64)
      TimeOverflow
    } derive(Eq, 
    Debug    )

    ClockSample

    source
    pub struct ClockSample {
      monotonic : Instant
      wall : WallTime
    } derive(Eq, 
    Debug    )

    ClockSample::monotonic

    source
    fn ClockSample::monotonic(self : ClockSample) -> Instant

    ClockSample::new

    source
    fn ClockSample::new(monotonic~ : Instant, wall~ : WallTime) -> ClockSample

    ClockSample::wall

    source
    fn ClockSample::wall(self : ClockSample) -> WallTime

    ClockSample::wall_at

    source
    fn ClockSample::wall_at(self : ClockSample, instant : Instant) -> WallTime raise TimeError

    ConnectionId

    source
    pub(all) struct ConnectionId(UInt64) derive(Eq, Hash, 
    Debug    )

    Duration

    source
    pub struct Duration(Int64) derive(Compare, Eq, 
    Debug    )

    Duration::as_milliseconds

    source
    fn Duration::as_milliseconds(self : Duration) -> Int64

    Duration::milliseconds

    source
    fn Duration::milliseconds(value : Int64) -> Duration raise TimeError

    Duration::zero

    source
    fn Duration::zero() -> Duration

    EcnCodepoint

    source
    pub(all) enum EcnCodepoint {
      Ect0
      Ect1
      CongestionExperienced
    } derive(Eq, 
    Debug    )

    InboundDatagram

    source
    pub(all) struct InboundDatagram {
      now : Instant
      context : TransportContext
      payload : Bytes
    } derive(Eq, 
    Debug    )

    Instant

    source
    pub struct Instant(Int64) derive(Compare, Eq, 
    Debug    )

    Instant::as_milliseconds

    source
    fn Instant::as_milliseconds(self : Instant) -> Int64

    Instant::checked_add

    source
    fn Instant::checked_add(self : Instant, duration : Duration) -> Instant raise TimeError

    Instant::from_milliseconds

    source
    fn Instant::from_milliseconds(value : Int64) -> Instant raise TimeError

    Instant::saturating_duration_since

    source
    fn Instant::saturating_duration_since(self : Instant, earlier : Instant) -> Duration

    IoAction

    source
    pub(all) enum IoAction {
      SendDatagram(OutboundDatagram)
      ConnectTcp(connection~ : ConnectionId, local_address~ : SocketAddress?, peer~ : SocketAddress)
      ConnectTls(connection~ : ConnectionId, local_address~ : SocketAddress?, peer~ : SocketAddress, server_name~ : String?)
      ListenTcp(listener~ : ListenerId, local_address~ : SocketAddress)
      WriteStream(connection~ : ConnectionId, bytes~ : Bytes)
      CloseStream(ConnectionId)
      CloseListener(ListenerId)
    } derive(Eq, 
    Debug    )

    IoEvent

    source
    pub(all) enum IoEvent {
      DatagramReceived(InboundDatagram)
      StreamConnected(now~ : Instant, connection~ : ConnectionId, context~ : TransportContext)
      StreamAccepted(now~ : Instant, listener~ : ListenerId, connection~ : ConnectionId, context~ : TransportContext)
      StreamBytes(now~ : Instant, connection~ : ConnectionId, bytes~ : Bytes)
      StreamWritable(now~ : Instant, connection~ : ConnectionId)
      StreamEof(now~ : Instant, connection~ : ConnectionId)
      StreamError(now~ : Instant, connection~ : ConnectionId, reason~ : String)
      StreamClosed(now~ : Instant, connection~ : ConnectionId)
    } derive(Eq, 
    Debug    )

    IpAddress

    source
    pub enum IpAddress {
      V4(UInt)
      V6(Bytes)
    } derive(Eq, 
    Debug    )

    IpAddress::is_unspecified

    source
    fn IpAddress::is_unspecified(self : IpAddress) -> Bool

    IpAddress::loopback_v4

    source
    fn IpAddress::loopback_v4() -> IpAddress

    IpAddress::parse

    source
    fn IpAddress::parse(value : String) -> IpAddress raise AddressError

    IpAddress::to_bytes

    source
    fn IpAddress::to_bytes(self : IpAddress) -> Bytes

    IpAddress::to_string

    source
    fn IpAddress::to_string(self : IpAddress) -> String

    IpAddress::v4

    source
    fn IpAddress::v4(a : Byte, b : Byte, c : Byte, d : Byte) -> IpAddress

    IpAddress::v6

    source
    fn IpAddress::v6(bytes : Bytes) -> IpAddress raise AddressError

    ListenerId

    source
    pub(all) struct ListenerId(UInt64) derive(Eq, Hash, 
    Debug    )

    ManualClock

    source
    pub struct ManualClock {
      monotonic : Instant
      wall : WallTime
    }

    ManualClock::advance

    source
    fn ManualClock::advance(self : ManualClock, duration : Duration) -> Unit raise TimeError

    ManualClock::new

    source
    fn ManualClock::new(sample : ClockSample) -> ManualClock

    ManualClock::sample

    source
    fn ManualClock::sample(self : ManualClock) -> ClockSample

    OutboundDatagram

    source
    pub(all) struct OutboundDatagram {
      context : TransportContext
      payload : Bytes
    } derive(Eq, 
    Debug    )

    SocketAddress

    source
    pub struct SocketAddress {
      address : IpAddress
      port : UInt16
    } derive(Eq, 
    Debug    )

    SocketAddress::address

    source
    fn SocketAddress::address(self : SocketAddress) -> IpAddress

    SocketAddress::new

    source
    fn SocketAddress::new(address~ : IpAddress, port~ : UInt16) -> SocketAddress

    SocketAddress::port

    source
    fn SocketAddress::port(self : SocketAddress) -> UInt16

    SocketAddress::to_string

    source
    fn SocketAddress::to_string(self : SocketAddress) -> String

    TransportContext

    source
    pub(all) struct TransportContext {
      local_address : SocketAddress
      peer : SocketAddress
      ecn : EcnCodepoint?
      protocol : TransportProtocol
    } derive(Eq, 
    Debug    )

    TransportProtocol

    source
    pub(all) enum TransportProtocol {
      Udp
      Tcp
    } derive(Eq, 
    Debug    )

    WallTime

    source
    pub struct WallTime(Int64) derive(Compare, Eq, 
    Debug    )

    WallTime::as_unix_nanoseconds

    source
    fn WallTime::as_unix_nanoseconds(self : WallTime) -> Int64

    WallTime::from_unix_nanoseconds

    source
    fn WallTime::from_unix_nanoseconds(value : Int64) -> WallTime

    Source Files

    Powered by MoonBit

    Site sourceReport issuePackagesBuild queueSkillsStatistics

    © 2026 mooncakes.io