Types
InvalidMplexMsgType = object of MuxerError
- Source Edit
MessageType {.pure.} = enum New, MsgIn, MsgOut, CloseIn, CloseOut, ResetIn, ResetOut
- Source Edit
Msg = tuple[id: uint64, msgType: MessageType, data: seq[byte]]
- Source Edit
Consts
MaxMsgSize = 1048576
- Source Edit
Procs
proc newInvalidMplexMsgType(): ref InvalidMplexMsgType {....raises: [], tags: [], forbids: [].}
- Source Edit
proc readMsg(conn: Connection): InternalRaisesFuture[Msg, (CancelledError, LPStreamError, MuxerError)] {....stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}
- Source Edit
proc writeMsg(conn: Connection; id: uint64; msgType: MessageType; data: seq[byte] = @[]): InternalRaisesFuture[void, (CancelledError, LPStreamError)] {....stackTrace: false, raises: [], gcsafe, raises: [], tags: [], forbids: [].}
- Source Edit
proc writeMsg(conn: Connection; id: uint64; msgType: MessageType; data: string): InternalRaisesFuture[ void, (CancelledError, LPStreamError)] {....stackTrace: false, raises: [], gcsafe, raises: [], tags: [], forbids: [].}
- Source Edit