/// Common implementation for all `handle_stream_` methods that query an
/// existing stream.
Common implementation for all `handle_stream_` methods that query an
existing stream.
Common implementation for all ` handle_stream_ ` methods that query an existing stream .
async fn handle_existing_stream_impl(
    msg_begin: StreamIndex,
    msg_limit: usize,
) -> ((u16, Vec<u8>), EndpointTestFixture) {
    let fixture = EndpointTestFixture::with_replicated_state();
    let url = Url::parse(&format!(
        "http://localhost/api/v1/stream/{}?msg_begin={}&msg_limit={}",
        DST_SUBNET, msg_begin, msg_limit
    ))
    .unwrap();
    let response = route_request(
        url,
        &*fixture.state_manager,
        &XNetEndpointMetrics::new(&fixture.metrics),
    );
    (parse_response(response).await, fixture)
}
async fn handle_existing_stream_impl ( msg_begin : StreamIndex , msg_limit : usize , ) -> ( ( u16 , Vec < u8 > ) , EndpointTestFixture ) { let fixture = EndpointTestFixture :: with_replicated_state ( ) ; let url = Url :: parse ( & format ! ( " " DST_SUBNET msg_begin msg_limit ) ) . unwrap ( ) ; let response = route_request ( url , & * fixture . state_manager , & XNetEndpointMetrics :: new ( & fixture . metrics ) , ) ; ( parse_response ( response ) . await , fixture ) }
Common implementation for all `handle_stream_` methods that query an
existing stream.
Common implementation for all ` handle_stream_ ` methods that query an existing stream .
msg_begin
StreamIndex
msg_limit
usize