[−][src]Struct fluvio_socket::InnerFlvSocket
Socket abstract that can send and receive fluvio objects
Implementations
impl<S> InnerFlvSocket<S>[src]
pub fn new(sink: InnerFlvSink<S>, stream: InnerFlvStream<S>) -> Self[src]
pub fn split(self) -> (InnerFlvSink<S>, InnerFlvStream<S>)[src]
pub fn set_stale(&mut self)[src]
mark as stale
pub fn is_stale(&self) -> bool[src]
pub fn get_mut_sink(&mut self) -> &mut InnerFlvSink<S>[src]
pub fn get_mut_stream(&mut self) -> &mut InnerFlvStream<S>[src]
pub fn id(&self) -> RawFd[src]
impl<S> InnerFlvSocket<S> where
S: AsyncRead + AsyncWrite + Unpin + Send, [src]
S: AsyncRead + AsyncWrite + Unpin + Send,
pub async fn connect_with_connector<C>(
addr: &str,
connector: &C
) -> Result<Self, FlvSocketError> where
C: TcpDomainConnector<WrapperStream = S>, [src]
addr: &str,
connector: &C
) -> Result<Self, FlvSocketError> where
C: TcpDomainConnector<WrapperStream = S>,
connect to target address with connector
pub fn from_stream(tcp_stream: S, raw_fd: RawFd) -> Self[src]
pub async fn send<R>(
&mut self,
req_msg: &RequestMessage<R>
) -> Result<ResponseMessage<R::Response>, FlvSocketError> where
R: Request, [src]
&mut self,
req_msg: &RequestMessage<R>
) -> Result<ResponseMessage<R::Response>, FlvSocketError> where
R: Request,
as client, send request and wait for reply from server
impl InnerFlvSocket<TcpStream>[src]
pub async fn connect(addr: &str) -> Result<Self, FlvSocketError>[src]
Trait Implementations
impl<S: Debug> Debug for InnerFlvSocket<S>[src]
impl<S> From<(InnerFlvSink<S>, InnerFlvStream<S>)> for InnerFlvSocket<S>[src]
pub fn from(pair: (InnerFlvSink<S>, InnerFlvStream<S>)) -> Self[src]
impl<S> Sync for InnerFlvSocket<S>[src]
Auto Trait Implementations
impl<S> !RefUnwindSafe for InnerFlvSocket<S>[src]
impl<S> Send for InnerFlvSocket<S> where
S: Send, [src]
S: Send,
impl<S> Unpin for InnerFlvSocket<S>[src]
impl<S> !UnwindSafe for InnerFlvSocket<S>[src]
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<T> Erased for T
impl<T> From<T> for T[src]
impl<T> Instrument for T[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>[src]
pub fn in_current_span(self) -> Instrumented<Self>[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,