proc init(C: type ChronosStream; client: StreamTransport; dir: Direction;
          timeout = DefaultChronosStreamTimeout;
          observedAddr: Opt[MultiAddress]; localAddr: Opt[MultiAddress]): ChronosStream {.
    ...raises: [].}

func shortLog(conn: ChronosStream): auto {....raises: [], tags: [], forbids: [].}

method atEof(s: ChronosStream): bool {....raises: [], tags: [], forbids: [].}

method closed(s: ChronosStream): bool {....raises: [], tags: [], forbids: [].}

method closeImpl(s: ChronosStream): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect],
    forbids: [].}

method closeWrite(s: ChronosStream): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect],
    forbids: [].}

method getWrapped(s: ChronosStream): Connection {....raises: [], tags: [],
    forbids: [].}

method initStream(s: ChronosStream) {....raises: [],
                                      tags: [TimeEffect, RootEffect],
                                      forbids: [].}

method readOnce(s: ChronosStream; pbytes: pointer; nbytes: int): InternalRaisesFuture[
    int, (CancelledError, LPStreamError)] {....stackTrace: false, raises: [],
    gcsafe, raises: [], tags: [RootEffect], forbids: [].}

method write(s: ChronosStream; msg: seq[byte]): InternalRaisesFuture[void,
    (CancelledError, LPStreamError)] {....stackTrace: false, raises: [], gcsafe,
                                       raises: [], tags: [RootEffect],
                                       forbids: [].}

template formatItIMPL(it: ChronosStream): auto {..}