• Home
  • Raw
  • Download

Lines Matching refs:poll_server

1912         pub fn poll_server(&mut self) -> Result<(u64, Event)> {  in poll_server()  method
2074 assert_eq!(s.poll_server(), Ok((stream, ev_headers))); in request_no_body_response_no_body()
2075 assert_eq!(s.poll_server(), Ok((stream, Event::Finished))); in request_no_body_response_no_body()
2103 assert_eq!(s.poll_server(), Ok((stream, ev_headers))); in request_no_body_response_one_chunk()
2105 assert_eq!(s.poll_server(), Ok((stream, Event::Finished))); in request_no_body_response_one_chunk()
2140 assert_eq!(s.poll_server(), Ok((stream, ev_headers))); in request_no_body_response_many_chunks()
2141 assert_eq!(s.poll_server(), Ok((stream, Event::Finished))); in request_no_body_response_many_chunks()
2188 assert_eq!(s.poll_server(), Ok((stream, ev_headers))); in request_one_chunk_response_no_body()
2190 assert_eq!(s.poll_server(), Ok((stream, Event::Data))); in request_one_chunk_response_no_body()
2193 assert_eq!(s.poll_server(), Ok((stream, Event::Finished))); in request_one_chunk_response_no_body()
2229 assert_eq!(s.poll_server(), Ok((stream, ev_headers))); in request_many_chunks_response_no_body()
2232 assert_eq!(s.poll_server(), Ok((stream, Event::Data))); in request_many_chunks_response_no_body()
2236 assert_eq!(s.poll_server(), Ok((stream, Event::Finished))); in request_many_chunks_response_no_body()
2283 let (stream, ev) = s.poll_server().unwrap(); in many_requests_many_chunks_response_one_chunk()
2289 assert_eq!(s.poll_server(), Ok((stream, Event::Data))); in many_requests_many_chunks_response_one_chunk()
2291 assert_eq!(s.poll_server(), Ok((stream, Event::Data))); in many_requests_many_chunks_response_one_chunk()
2293 assert_eq!(s.poll_server(), Ok((stream, Event::Finished))); in many_requests_many_chunks_response_one_chunk()
2296 assert_eq!(s.poll_server(), Err(Error::Done)); in many_requests_many_chunks_response_one_chunk()
2336 assert_eq!(s.poll_server(), Ok((stream, ev_headers))); in body_response_before_headers()
2338 assert_eq!(s.poll_server(), Ok((stream, Event::Finished))); in body_response_before_headers()
2465 assert_eq!(s.poll_server(), Err(Error::Done)); in max_push_id_from_client_good()
2488 assert_eq!(s.poll_server(), Ok((stream, ev_headers))); in max_push_id_from_client_bad_stream()
2489 assert_eq!(s.poll_server(), Err(Error::FrameUnexpected)); in max_push_id_from_client_bad_stream()
2513 assert_eq!(s.poll_server(), Err(Error::IdError)); in max_push_id_from_client_limit_reduction()
2557 assert_eq!(s.poll_server(), Ok((stream, ev_headers))); in push_promise_from_client()
2558 assert_eq!(s.poll_server(), Err(Error::FrameUnexpected)); in push_promise_from_client()
2574 assert_eq!(s.poll_server(), Err(Error::Done)); in cancel_push_from_client()
2597 assert_eq!(s.poll_server(), Ok((stream, ev_headers))); in cancel_push_from_client_bad_stream()
2598 assert_eq!(s.poll_server(), Err(Error::FrameUnexpected)); in cancel_push_from_client_bad_stream()
2628 assert_eq!(s.poll_server(), Err(Error::Done)); in goaway_from_client_good()
2735 assert_eq!(s.poll_server(), Err(Error::StreamCreationError)); in open_multiple_control_streams()
2921 assert_eq!(s.poll_server(), Ok((stream, ev_headers))); in stream_backpressure()
2924 assert_eq!(s.poll_server(), Ok((stream, Event::Data))); in stream_backpressure()
2931 assert_eq!(s.poll_server(), Ok((stream, Event::Data))); in stream_backpressure()
2939 assert_eq!(s.poll_server(), Err(Error::Done)); in stream_backpressure()
2985 assert_eq!(s.poll_server(), Err(Error::ExcessiveLoad)); in request_max_header_size_limit()