Searched refs:State (Results 1 – 4 of 4) sorted by relevance
| /tonic/tonic/src/transport/channel/service/ |
| H A D | reconnect.rs | 18 state: State<M::Future, M::Response>,
26 enum State<F, S> { enum
40 state: State::Idle, in new()
71 State::Idle => { in poll_ready()
82 self.state = State::Connecting(fut); in poll_ready()
85 State::Connecting(ref mut f) => { in poll_ready()
89 state = State::Connected(service); in poll_ready()
98 state = State::Idle; in poll_ready()
111 State::Connected(ref mut inner) => { in poll_ready()
127 state = State::Idle; in poll_ready()
[all …]
|
| /tonic/tonic/src/codec/ |
| H A D | decode.rs | 28 state: State,
40 enum State { enum
134 state: State::ReadHeader, in new()
151 if let State::ReadHeader = self.state { in decode_chunk()
200 self.state = State::ReadBody { in decode_chunk()
206 if let State::ReadBody { len, compression } = self.state { in decode_chunk()
256 let _ = std::mem::replace(&mut self.state, State::Error(Some(status.clone()))); in poll_frame()
376 self.inner.state = State::ReadHeader; in decode_chunk()
394 if let State::Error(status) = &mut self.inner.state { in poll_next()
|
| /tonic/tonic/src/transport/server/ |
| H A D | io_stream.rs | 23 struct State<IO>(TlsAcceptor, JoinSet<Result<ServerIo<IO>, crate::BoxError>>); struct
33 state: Option<State<IO>>,
44 state: tls.map(|tls| State(tls, JoinSet::new())), in new()
86 let Some(State(tls, tasks)) = projected.state else { in poll_next()
|
| /tonic/examples/proto/googleapis/google/api/ |
| H A D | field_behavior.proto | 34 // State state = 1 [(google.api.field_behavior) = OUTPUT_ONLY];
|