1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

// Copyright (c) The Diem Core Contributors
// SPDX-License-Identifier: Apache-2.0

use crate::stream_rpc::{errors::StreamError, transport::util::Transport};
use futures::Stream;
use tokio::sync::mpsc;

pub type StreamSender = mpsc::Sender<Result<String, StreamError>>;

pub type BoxConnectionStream =
    Box<dyn Stream<Item = Result<Option<String>, StreamError>> + Send + Unpin>;

#[derive(Clone, Debug)]
pub struct ConnectionContext {
    pub transport: Transport,
    pub sdk_info: crate::util::SdkInfo,
    pub remote_addr: Option<String>,
}