Imports

Types

LPProtocol = ref object of RootObj codecs*: seq[string] ## invoked by the protocol negotiator started*: bool: Source Edit
LPProtoHandler = proc (conn: Connection; proto: string): Future[void] {. async: (...raises: [CancelledError]).}: Source Edit

func codec(p: LPProtocol): string {....raises: [], tags: [], forbids: [].}: Source Edit
func codec=(p: LPProtocol; codec: string) {....raises: [], tags: [], forbids: [].}: Source Edit
func handler=(p: LPProtocol; handler: LPProtoHandler) {....raises: [], tags: [], forbids: [].}: Source Edit
proc maxIncomingStreams(p: LPProtocol): int {....raises: [], tags: [], forbids: [].}: Source Edit
proc maxIncomingStreams=(p: LPProtocol; val: int) {....raises: [], tags: [], forbids: [].}: Source Edit
proc new(T: type LPProtocol; codecs: seq[string]; handler: LPProtoHandler; maxIncomingStreams: Opt[int] | int = Opt.none(int)): T:type {. ...raises: [].}: Source Edit

method init(p: LPProtocol) {.base, ...gcsafe, raises: [], tags: [], forbids: [].}: Source Edit
method start(p: LPProtocol): InternalRaisesFuture[void, (CancelledError,)] {. base, ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [], forbids: [].}: Source Edit
method stop(p: LPProtocol): InternalRaisesFuture[void, void] {.base, ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [], forbids: [].}: Source Edit

template handler(p: LPProtocol): LPProtoHandler {..}: Source Edit
template handler(p: LPProtocol; conn: Connection; proto: string): Future[void] {..}: Source Edit