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): InternalRaisesFuture[void, void] {.
    stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
    tags: [RootEffect].}

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

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

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

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

template formatItIMPL(it: ChronosStream): auto