diff --git a/Cargo.lock b/Cargo.lock index 2e697e59..96f41d34 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -1630,9 +1630,9 @@ dependencies = [ [[package]] name = "obix" -version = "0.14.4" +version = "0.15.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "dc0d2082bbad7a3ee648902bb07a0ed86f0e128689dd6f848fa85561bbc3527c" +checksum = "69a179fb88849453c776a108424aeca96c66d84677f9898673234e80870489b3" dependencies = [ "async-trait", "bon", @@ -1652,9 +1652,9 @@ dependencies = [ [[package]] name = "obix-macros" -version = "0.14.4" +version = "0.15.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "edba34aa7f28936e54726c6314f57d85dfb7d3793dfb0961e65b9c669bcac9ba" +checksum = "8e948b04490f3bc5f27bbb5fbd74fd1170400a465a1f31072d70fa0610a37d85" dependencies = [ "darling 0.24.0", "proc-macro2", diff --git a/Cargo.toml b/Cargo.toml index 441c4d2b..f0f48675 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -17,7 +17,7 @@ cala-ledger = { path = "cala-ledger", version = "0.33.1-dev" } cel = "0.14.5" es-entity = { version = "0.20.0", features = ["errlanes-tracing"] } job = { version = "0.18.5", features = ["es-entity"] } -obix = { version = "0.14.4", default-features = false } +obix = { version = "0.15.0", default-features = false } anyhow = "1.0.99" cached = { version = "4.0", features = ["async"] } diff --git a/cala-ledger/src/ec_rollup.rs b/cala-ledger/src/ec_rollup.rs index c87f4e4c..53f6f1d4 100644 --- a/cala-ledger/src/ec_rollup.rs +++ b/cala-ledger/src/ec_rollup.rs @@ -54,7 +54,7 @@ use job::{JobType, Jobs}; use obix::{ out::{ EventCtx, EventDelivery, FlushOp, Handled, InsertOrder, OutboxEventJobConfig, - PersistentOutboxEvent, SingletonSubscriber, StreamSelection, Subscription, + PersistentOutboxEvent, SingletonSubscriber, Subscription, }, EventSequence, }; @@ -237,8 +237,6 @@ struct EcBalanceRollupHandler { } impl SingletonSubscriber for EcBalanceRollupHandler { - const SUBSCRIPTION: StreamSelection = StreamSelection::PersistentOnly; - type Batch = EcRollupBatch; async fn handle_persistent<'inv>(