Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

chore(sequencer-relayer): change blob submitter to use boxed blocks #1863

Open
wants to merge 7 commits into
base: main
Choose a base branch
from
Open

chore(sequencer-relayer): change blob submitter to use boxed blocks #1863

Show file tree
Hide file tree
Changes from 5 commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
dda57ad
bump msrv
ethanoroshiba Dec 6, 2024
5e31245
update changelogs, add issue links
ethanoroshiba Dec 6, 2024
b889486
fix err
ethanoroshiba Dec 6, 2024
6a0de65
Revert "update changelogs, add issue links"
ethanoroshiba Dec 6, 2024
a7e6ef5
Revert "bump msrv"
ethanoroshiba Dec 6, 2024
d113119
requested changes
ethanoroshiba Dec 9, 2024
7ef3361
make type alias for complicated type
ethanoroshiba Dec 10, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion crates/astria-sequencer-relayer/src/relayer/mod.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
use std::{

Check failure on line 1 in crates/astria-sequencer-relayer/src/relayer/mod.rs

View workflow job for this annotation

GitHub Actions / Code Freeze

Code Freeze in Effect 

This file is under code freeze.

Check failure on line 1 in crates/astria-sequencer-relayer/src/relayer/mod.rs

View workflow job for this annotation

GitHub Actions / Code Freeze

Code Freeze in Effect 

This file is under code freeze.

Check failure on line 1 in crates/astria-sequencer-relayer/src/relayer/mod.rs

View workflow job for this annotation

GitHub Actions / Code Freeze

Code Freeze in Effect 

This file is under code freeze.

Check warning on line 1 in crates/astria-sequencer-relayer/src/relayer/mod.rs

View workflow job for this annotation

GitHub Actions / Code Freeze

Code Freeze in Effect - Bypassed 

This file is under code freeze.
path::PathBuf,
sync::Arc,
time::Duration,
Expand Down Expand Up @@ -302,7 +302,7 @@
block_stream.pause();
debug!("block stream paused");

match error {
match *error {
TrySendError::Full(block) => {
*forward = async move { submitter.send(block).await }.boxed().fuse();
}
Expand Down
4 changes: 2 additions & 2 deletions crates/astria-sequencer-relayer/src/relayer/write/mod.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
//! A task writing sequencer blocks to Celestia.

Check failure on line 1 in crates/astria-sequencer-relayer/src/relayer/write/mod.rs

View workflow job for this annotation

GitHub Actions / Code Freeze

Code Freeze in Effect 

This file is under code freeze.

Check failure on line 1 in crates/astria-sequencer-relayer/src/relayer/write/mod.rs

View workflow job for this annotation

GitHub Actions / Code Freeze

Code Freeze in Effect 

This file is under code freeze.

Check failure on line 1 in crates/astria-sequencer-relayer/src/relayer/write/mod.rs

View workflow job for this annotation

GitHub Actions / Code Freeze

Code Freeze in Effect 

This file is under code freeze.

Check warning on line 1 in crates/astria-sequencer-relayer/src/relayer/write/mod.rs

View workflow job for this annotation

GitHub Actions / Code Freeze

Code Freeze in Effect - Bypassed 

This file is under code freeze.
//!
//! [`BlobSubmitter`] receives [`SequencerBlock`]s over a channel,
//! converts them to Celestia [`Blob`]s, and writes them to Celestia
Expand Down Expand Up @@ -96,8 +96,8 @@
pub(super) fn try_send(
&self,
block: SequencerBlock,
ethanoroshiba marked this conversation as resolved.
Show resolved Hide resolved
) -> Result<(), TrySendError<SequencerBlock>> {
self.tx.try_send(block)
) -> Result<(), Box<TrySendError<SequencerBlock>>> {
self.tx.try_send(block).map_err(Box::new)
}

/// Sends a block to the blob submitter.
Expand Down
Loading