Struct SourceProxyBuilder

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

Implementations

impl<Response, Context> SourceProxyBuilder<Response, Context>

where Response: Future<Output = Result<BootstrapStream, BootstrapError>> + Send + Sync, Context: Send + Sync + Clone + 'static,

pub fn new() -> Self

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

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

pub fn with_context(self, context: Context) -> Self

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

impl<Response> SourceProxyBuilder<Response, ()>

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

pub fn without_context(self) -> Self