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: MultiAddress = MultiAddress()): ChronosStream {.
    ...raises: [Defect].}

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

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

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

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

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

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

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

template formatItIMPL(it: ChronosStream): auto