ChronosStream = ref object of Connection
  client: StreamTransport
  when defined(libp2p_agents_metrics):
      tracked: bool

  

ChronosStreamTrackerName = "ChronosStream"

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

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

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

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

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

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

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

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

method write(s: ChronosStream; msg: seq[byte]): Future[void] {....raises: [],
    tags: [RootEffect].}

template formatItIMPL(it: ChronosStream): auto