We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3c66163 commit 71d594eCopy full SHA for 71d594e
src/utils.rs
@@ -9,7 +9,7 @@ pub async fn setup_jetstream(nats_client: &async_nats::Client) -> Result<jetstre
9
let stream_config = stream::Config {
10
name: "PYTH_PRICE_UPDATES".to_string(),
11
subjects: vec!["pyth.price.updates".to_string()],
12
- max_bytes: 1024 * 1024 * 1000,
+ max_bytes: 1024 * 1024 * 4000,
13
duplicate_window: Duration::from_secs(60),
14
discard: stream::DiscardPolicy::Old,
15
allow_direct: true,
0 commit comments