Imports

Types

Muxer = ref object of RootObj streamHandler*: StreamHandler handler*: Future[void].Raising([]) connection*: Connection: Source Edit
MuxerConstructor = proc (conn: Connection): Muxer {....gcsafe, closure, ...raises: [].}: Source Edit
MuxerError = object of LPError: Source Edit
MuxerHandler = proc (muxer: Muxer): Future[void] {.async: (...raises: []).}: Source Edit
MuxerProvider = object newMuxer*: MuxerConstructor codec*: string: Source Edit
StreamHandler = proc (conn: Connection): Future[void] {.async: (...raises: []).}: Source Edit
TooManyChannels = object of MuxerError: Source Edit

proc new(T: typedesc[MuxerProvider]; creator: MuxerConstructor; codec: string): T:type {. ...gcsafe, raises: [].}: Source Edit
func shortLog(m: Muxer): auto {....raises: [], tags: [], forbids: [].}: Source Edit

method close(m: Muxer): InternalRaisesFuture[void, void] {.base, ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}: Source Edit
method getStreams(m: Muxer): seq[Connection] {.base, ...gcsafe, raises: [], tags: [], forbids: [].}: Source Edit
method handle(m: Muxer): InternalRaisesFuture[void, void] {.base, ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}: Source Edit
method newStream(m: Muxer; name: string = ""; lazy: bool = false): InternalRaisesFuture[ Connection, (CancelledError, LPStreamError, MuxerError)] {.base, ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [], forbids: [].}: Source Edit