dynamo-runtime-0.7.0
- dynamo-runtime 0.7.0
- Docs.rs crate page
- Apache-2.0
- Links
- Homepage
- Repository
- crates.io
- Source
- Dependencies
- anyhow ^1 normal
  arc-swap ^1 normal
  async-nats ^0.40 normal
  async-once-cell ^0.5.4 normal
  async-stream ^0.3 normal
  async-trait ^0.1 normal
  async_zmq ^0.4.0 normal
  axum ^0.8 normal
  bincode ^1 normal
  blake3 ^1 normal
  bytes ^1 normal
  chrono ^0.4 normal
  console-subscriber ^0.4 normal optional
  dashmap ^6.1 normal
  derive-getters ^0.5 normal
  derive_builder ^0.20 normal
  educe ^0.6.0 normal
  either ^1.13 normal
  etcd-client ^0.16 normal
  figment ^0.10.19 normal
  futures ^0.3 normal
  humantime ^2.2.0 normal
  hyper ^1.5 normal
  hyper-util ^0.1 normal
  inotify ^0.11 normal
  k8s-openapi ^0.26.0 normal
  kube ^2.0.1 normal
  libc ^0.2 normal
  local-ip-address ^0.6.3 normal
  log ^0.4 normal
  nid ^3.0.0 normal
  nix ^0.29 normal
  nuid ^0.5 normal
  once_cell ^1 normal
  opentelemetry ^0.31.0 normal
  opentelemetry-otlp ^0.31.0 normal
  opentelemetry_sdk ^0.31.0 normal
  parking_lot ^0.12.5 normal
  prometheus ^0.14 normal
  rand ^0.9.0 normal
  rayon ^1.10 normal
  regex ^1 normal
  reqwest ^0.12.22 normal
  rmp-serde ^1 normal
  serde ^1 normal
  serde_json ^1 normal
  socket2 ^0.5.8 normal
  thiserror ^2.0.11 normal
  tokio ^1 normal
  tokio-rayon ^2.1 normal
  tokio-stream ^0.1 normal
  tokio-util ^0.7 normal
  tower ^0.5 normal
  tower-http ^0.6 normal
  tracing ^0.1 normal
  tracing-opentelemetry ^0.32.0 normal
  tracing-subscriber ^0.3 normal
  url ^2.5 normal
  uuid ^1.17 normal
  validator ^0.20.0 normal
  xxhash-rust ^0.8 normal
  assert_matches ^1.5.0 dev
  criterion ^0.5 dev
  env_logger ^0.11 dev
  jsonschema ^0.17 dev
  rstest ^0.23.0 dev
  stdio-override ^0.2.0 dev
  temp-env ^0.3.6 dev
  tempfile ^3 dev
- Versions
- 62.87% of the crate is documented
Go to latest version
Platform
- x86_64-unknown-linux-gnu
Feature flags

docs.rs

Rust

until_deadline

dynamo_runtime0.7.0

In dynamo_runtime::utils::stream

dynamo_runtime::utils::stream

Function until_deadline

pub fn until_deadline<S: Stream + Unpin>(
    stream: S,
    deadline: Instant,
) -> DeadlineStream<S>