Struct SourceProxyBuilder

pub struct SourceProxyBuilder<Response>
where
    Response: Future<Output = Result<BootstrapStream, BootstrapError>> + Send + Sync,
{ /* private fields */ }

Implementations

impl<Response> SourceProxyBuilder<Response>

where Response: Future<Output = Result<BootstrapStream, BootstrapError>> + Send + Sync,

pub fn new() -> Self

pub fn with_stream_producer( self, stream_producer: fn(_: BootstrapRequest) -> Response, ) -> Self

pub fn with_port(self, port: u16) -> Self

pub fn build(self) -> SourceProxy<Response>