Skip to main content

HttpFcbReader

Struct HttpFcbReader 

Source
pub struct HttpFcbReader<T: AsyncHttpRangeClient + Send + Sync> { /* private fields */ }
Expand description

FlatCityBuf dataset HTTP reader

Implementations§

Source§

impl HttpFcbReader<Client>

Source

pub async fn open(url: &str) -> Result<HttpFcbReader<Client>>

Source§

impl<T: AsyncHttpRangeClient + Send + Sync> HttpFcbReader<T>

Source

pub async fn new( client: AsyncBufferedHttpRangeClient<T>, ) -> Result<HttpFcbReader<T>>

Source

pub fn header(&self) -> Header<'_>

Source

pub async fn select_all(self) -> Result<AsyncFeatureIter<T>>

Select all features.

Source

pub async fn select_query(self, query: Query) -> Result<AsyncFeatureIter<T>>

Select features within a bounding box.

Source

pub async fn select_query_paged( self, query: Query, limit: Option<usize>, offset: Option<usize>, ) -> Result<AsyncFeatureIter<T>>

Select features within a bounding box with optional pagination. If limit/offset are provided, only a page of features is returned while features_count() on the returned iterator still reflects the total number of matches.

Source

pub async fn select_attr_query( self, query: &AttrQuery, ) -> Result<AsyncFeatureIter<T>>

This method uses the attribute index section to find matching feature offsets. It then groups (batches) the remote feature ranges in order to reduce IO overhead.

Source

pub async fn select_attr_query_paged( self, query: &AttrQuery, limit: Option<usize>, offset: Option<usize>, ) -> Result<AsyncFeatureIter<T>>

Attribute query with optional pagination where the iterator returns only the requested page, while features_count() reflects the total number of matches.

Source

pub fn add_indices_to_multi_http_index<C: AsyncHttpRangeClient + Send + Sync>( multi_index: &mut HttpMultiIndex<C>, columns: &[Column<'_>], attr_info: &AttributeIndex, index_begin: usize, feature_begin: usize, ) -> Result<()>

Auto Trait Implementations§

§

impl<T> Freeze for HttpFcbReader<T>
where T: Freeze,

§

impl<T> RefUnwindSafe for HttpFcbReader<T>
where T: RefUnwindSafe,

§

impl<T> Send for HttpFcbReader<T>

§

impl<T> Sync for HttpFcbReader<T>

§

impl<T> Unpin for HttpFcbReader<T>
where T: Unpin,

§

impl<T> UnsafeUnpin for HttpFcbReader<T>
where T: UnsafeUnpin,

§

impl<T> UnwindSafe for HttpFcbReader<T>
where T: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

§

impl<T> PolicyExt for T
where T: ?Sized,

§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns [Action::Follow] only if self and other return Action::Follow. Read more
§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns [Action::Follow] if either self or other returns Action::Follow. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,