@Test(timeout = 60000) public void testGetMethod() throws Exception { assertThat("Unexpected http version", requestRule.request.getMethod(), is(HttpMethod.GET)); }
@Override public HttpMethod getMethod() { return rawRequest.getHeaders().method(); }
HttpClientRequestImpl extends HttpClientRequest<I, O> { @Override public HttpMethod getMethod() { return rawRequest.getHeaders().method(); } }
HttpClientRequestImpl extends HttpClientRequest<I, O> { @Override public HttpMethod getMethod() { return rawRequest.getHeaders().method(); } private  HttpClientRequestImpl(final RawRequest<I, O> rawRequest, final TcpClient<?, HttpClientResponse<O>> client,
                                  List<AppendTransformerEvent> immutableTransformers,
                                  List<Transformer> immutableResponseTransformers); }
HttpClientRequestImpl extends HttpClientRequest<I, O> { @Override public HttpMethod getMethod() { return rawRequest.getHeaders().method(); } private  HttpClientRequestImpl(final RawRequest<I, O> rawRequest, final TcpClient<?, HttpClientResponse<O>> client,
                                  List<AppendTransformerEvent> immutableTransformers,
                                  List<Transformer> immutableResponseTransformers); @Override Observable<HttpClientResponse<O>> writeContent(Observable<I> contentSource); @Override Observable<HttpClientResponse<O>> writeContentAndFlushOnEach(Observable<I> contentSource); @Override Observable<HttpClientResponse<O>> writeStringContent(Observable<String> contentSource); @Override Observable<HttpClientResponse<O>> writeBytesContent(Observable<byte[]> contentSource); @Override Observable<HttpClientResponse<O>> writeContent(Observable<I> contentSource,
                                                          Func1<I, Boolean> flushSelector); @Override Observable<HttpClientResponse<O>> writeStringContent(Observable<String> contentSource,
                                                                Func1<String, Boolean> flushSelector); @Override Observable<HttpClientResponse<O>> writeBytesContent(Observable<byte[]> contentSource,
                                                               Func1<byte[], Boolean> flushSelector); @Override Observable<HttpClientResponse<O>> writeContent(Observable<I> contentSource,
                                                                              final Func0<T> trailerFactory,
                                                                              final Func2<T, I, T> trailerMutator); @Override Observable<HttpClientResponse<O>> writeStringContent(Observable<String> contentSource,
                                                                                    Func0<T> trailerFactory,
                                                                                    Func2<T, String, T> trailerMutator); @Override Observable<HttpClientResponse<O>> writeBytesContent(Observable<byte[]> contentSource,
                                                                                   Func0<T> trailerFactory,
                                                                                   Func2<T, byte[], T> trailerMutator); @Override Observable<HttpClientResponse<O>> writeContent(Observable<I> contentSource,
                                                                                      Func0<T> trailerFactory,
                                                                                      Func2<T, I, T> trailerMutator,
                                                                                      Func1<I, Boolean> flushSelector); @Override Observable<HttpClientResponse<O>> writeStringContent(
            Observable<String> contentSource, Func0<T> trailerFactory, Func2<T, String, T> trailerMutator,
            Func1<String, Boolean> flushSelector); @Override Observable<HttpClientResponse<O>> writeBytesContent(
            Observable<byte[]> contentSource, Func0<T> trailerFactory, Func2<T, byte[], T> trailerMutator,
            Func1<byte[], Boolean> flushSelector); @Override HttpClientRequestImpl<I, O> readTimeOut(int timeOut, TimeUnit timeUnit); @Override HttpClientRequestImpl<I, O> followRedirects(int maxRedirects); @Override HttpClientRequestImpl<I, O> followRedirects(boolean follow); @Override HttpClientRequestImpl<I, O> setMethod(HttpMethod method); @Override HttpClientRequestImpl<I, O> setUri(String newUri); @Override HttpClientRequestImpl<I, O> addHeader(CharSequence name, Object value); @Override HttpClientRequest<I, O> addHeaders(Map<? extends CharSequence, ? extends Iterable<Object>> headers); @Override HttpClientRequestImpl<I, O> addCookie(Cookie cookie); @Override HttpClientRequestImpl<I, O> addDateHeader(CharSequence name, Date value); @Override HttpClientRequestImpl<I, O> addDateHeader(CharSequence name, Iterable<Date> values); @Override HttpClientRequestImpl<I, O> addHeaderValues(CharSequence name, Iterable<Object> values); @Override HttpClientRequestImpl<I, O> setDateHeader(CharSequence name, Date value); @Override HttpClientRequestImpl<I, O> setHeader(CharSequence name, Object value); @Override HttpClientRequest<I, O> setHeaders(Map<? extends CharSequence, ? extends Iterable<Object>> headers); @Override HttpClientRequestImpl<I, O> setDateHeader(CharSequence name, Iterable<Date> values); @Override HttpClientRequestImpl<I, O> setHeaderValues(CharSequence name, Iterable<Object> values); @Override HttpClientRequestImpl<I, O> removeHeader(CharSequence name); @Override HttpClientRequestImpl<I, O> setKeepAlive(boolean keepAlive); @Override HttpClientRequestImpl<I, O> setTransferEncodingChunked(); @Override HttpClientRequestImpl<II, O> transformContent(AllocatingTransformer<II, I> transformer); @Override HttpClientRequestImpl<I, OO> transformResponseContent(Transformer<O, OO> transformer); @Override WebSocketRequestImpl<O> requestWebSocketUpgrade(); @Override boolean containsHeader(CharSequence name); @Override boolean containsHeaderWithValue(CharSequence name, CharSequence value, boolean caseInsensitiveValueMatch); @Override String getHeader(CharSequence name); @Override List<String> getAllHeaders(CharSequence name); @Override Iterator<Entry<CharSequence, CharSequence>> headerIterator(); @Override Set<String> getHeaderNames(); @Override HttpVersion getHttpVersion(); @Override HttpMethod getMethod(); @Override String getUri(); static HttpClientRequestImpl<I, O> create(final HttpVersion version, final HttpMethod httpMethod,
                                                        final String uri,
                                                        final TcpClient<?, HttpClientResponse<O>> client,
                                                        int maxRedirects); static HttpClientRequestImpl<I, O> create(final HttpVersion version, final HttpMethod httpMethod,
                                                        final String uri,
                                                        final TcpClient<?, HttpClientResponse<O>> client); static HttpClientRequestImpl<I, O> create(final RawRequest<I, O> rawRequest,
                                                        final TcpClient<?, HttpClientResponse<O>> client); TcpClient<?, HttpClientResponse<O>> getClient(); RawRequest<I, O> unsafeRawRequest(); }
HttpClientRequestImpl extends HttpClientRequest<I, O> { @Override public HttpMethod getMethod() { return rawRequest.getHeaders().method(); } private  HttpClientRequestImpl(final RawRequest<I, O> rawRequest, final TcpClient<?, HttpClientResponse<O>> client,
                                  List<AppendTransformerEvent> immutableTransformers,
                                  List<Transformer> immutableResponseTransformers); @Override Observable<HttpClientResponse<O>> writeContent(Observable<I> contentSource); @Override Observable<HttpClientResponse<O>> writeContentAndFlushOnEach(Observable<I> contentSource); @Override Observable<HttpClientResponse<O>> writeStringContent(Observable<String> contentSource); @Override Observable<HttpClientResponse<O>> writeBytesContent(Observable<byte[]> contentSource); @Override Observable<HttpClientResponse<O>> writeContent(Observable<I> contentSource,
                                                          Func1<I, Boolean> flushSelector); @Override Observable<HttpClientResponse<O>> writeStringContent(Observable<String> contentSource,
                                                                Func1<String, Boolean> flushSelector); @Override Observable<HttpClientResponse<O>> writeBytesContent(Observable<byte[]> contentSource,
                                                               Func1<byte[], Boolean> flushSelector); @Override Observable<HttpClientResponse<O>> writeContent(Observable<I> contentSource,
                                                                              final Func0<T> trailerFactory,
                                                                              final Func2<T, I, T> trailerMutator); @Override Observable<HttpClientResponse<O>> writeStringContent(Observable<String> contentSource,
                                                                                    Func0<T> trailerFactory,
                                                                                    Func2<T, String, T> trailerMutator); @Override Observable<HttpClientResponse<O>> writeBytesContent(Observable<byte[]> contentSource,
                                                                                   Func0<T> trailerFactory,
                                                                                   Func2<T, byte[], T> trailerMutator); @Override Observable<HttpClientResponse<O>> writeContent(Observable<I> contentSource,
                                                                                      Func0<T> trailerFactory,
                                                                                      Func2<T, I, T> trailerMutator,
                                                                                      Func1<I, Boolean> flushSelector); @Override Observable<HttpClientResponse<O>> writeStringContent(
            Observable<String> contentSource, Func0<T> trailerFactory, Func2<T, String, T> trailerMutator,
            Func1<String, Boolean> flushSelector); @Override Observable<HttpClientResponse<O>> writeBytesContent(
            Observable<byte[]> contentSource, Func0<T> trailerFactory, Func2<T, byte[], T> trailerMutator,
            Func1<byte[], Boolean> flushSelector); @Override HttpClientRequestImpl<I, O> readTimeOut(int timeOut, TimeUnit timeUnit); @Override HttpClientRequestImpl<I, O> followRedirects(int maxRedirects); @Override HttpClientRequestImpl<I, O> followRedirects(boolean follow); @Override HttpClientRequestImpl<I, O> setMethod(HttpMethod method); @Override HttpClientRequestImpl<I, O> setUri(String newUri); @Override HttpClientRequestImpl<I, O> addHeader(CharSequence name, Object value); @Override HttpClientRequest<I, O> addHeaders(Map<? extends CharSequence, ? extends Iterable<Object>> headers); @Override HttpClientRequestImpl<I, O> addCookie(Cookie cookie); @Override HttpClientRequestImpl<I, O> addDateHeader(CharSequence name, Date value); @Override HttpClientRequestImpl<I, O> addDateHeader(CharSequence name, Iterable<Date> values); @Override HttpClientRequestImpl<I, O> addHeaderValues(CharSequence name, Iterable<Object> values); @Override HttpClientRequestImpl<I, O> setDateHeader(CharSequence name, Date value); @Override HttpClientRequestImpl<I, O> setHeader(CharSequence name, Object value); @Override HttpClientRequest<I, O> setHeaders(Map<? extends CharSequence, ? extends Iterable<Object>> headers); @Override HttpClientRequestImpl<I, O> setDateHeader(CharSequence name, Iterable<Date> values); @Override HttpClientRequestImpl<I, O> setHeaderValues(CharSequence name, Iterable<Object> values); @Override HttpClientRequestImpl<I, O> removeHeader(CharSequence name); @Override HttpClientRequestImpl<I, O> setKeepAlive(boolean keepAlive); @Override HttpClientRequestImpl<I, O> setTransferEncodingChunked(); @Override HttpClientRequestImpl<II, O> transformContent(AllocatingTransformer<II, I> transformer); @Override HttpClientRequestImpl<I, OO> transformResponseContent(Transformer<O, OO> transformer); @Override WebSocketRequestImpl<O> requestWebSocketUpgrade(); @Override boolean containsHeader(CharSequence name); @Override boolean containsHeaderWithValue(CharSequence name, CharSequence value, boolean caseInsensitiveValueMatch); @Override String getHeader(CharSequence name); @Override List<String> getAllHeaders(CharSequence name); @Override Iterator<Entry<CharSequence, CharSequence>> headerIterator(); @Override Set<String> getHeaderNames(); @Override HttpVersion getHttpVersion(); @Override HttpMethod getMethod(); @Override String getUri(); static HttpClientRequestImpl<I, O> create(final HttpVersion version, final HttpMethod httpMethod,
                                                        final String uri,
                                                        final TcpClient<?, HttpClientResponse<O>> client,
                                                        int maxRedirects); static HttpClientRequestImpl<I, O> create(final HttpVersion version, final HttpMethod httpMethod,
                                                        final String uri,
                                                        final TcpClient<?, HttpClientResponse<O>> client); static HttpClientRequestImpl<I, O> create(final RawRequest<I, O> rawRequest,
                                                        final TcpClient<?, HttpClientResponse<O>> client); TcpClient<?, HttpClientResponse<O>> getClient(); RawRequest<I, O> unsafeRawRequest(); static final int NO_REDIRECTS; }