Skip to content

Commit c4b823c

Browse files
committed
Fix kdb_write doctest by wrapping example in function
1 parent a73cdcf commit c4b823c

File tree

1 file changed

+9
-5
lines changed

1 file changed

+9
-5
lines changed

wingfoil/src/adapters/kdb/write.rs

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@ pub trait KdbSerialize: Sized {
4343
/// ```ignore
4444
/// use wingfoil::adapters::kdb::*;
4545
/// use wingfoil::*;
46+
/// use std::time::Duration;
4647
///
4748
/// #[derive(Debug, Clone, Default)]
4849
/// struct Trade {
@@ -61,11 +62,14 @@ pub trait KdbSerialize: Sized {
6162
/// }
6263
/// }
6364
///
64-
/// let conn = KdbConnection::new("localhost", 5000);
65-
/// let trades: Rc<dyn Stream<TinyVec<[Trade; 1]>>> = /* ... */;
66-
/// kdb_write(conn, "trades", &trades)
67-
/// .run(RunMode::RealTime, RunFor::Duration(Duration::from_secs(10)))
68-
/// .unwrap();
65+
/// fn example() {
66+
/// let conn = KdbConnection::new("localhost", 5000);
67+
/// let trades: Rc<dyn Stream<TinyVec<[Trade; 1]>>> = /* ... */
68+
/// # panic!("example code");
69+
/// kdb_write(conn, "trades", &trades)
70+
/// .run(RunMode::RealTime, RunFor::Duration(Duration::from_secs(10)))
71+
/// .unwrap();
72+
/// }
6973
/// ```
7074
pub fn kdb_write<T>(
7175
connection: KdbConnection,

0 commit comments

Comments
 (0)