@Test public void testIsStreamingScheme() { URI uri = null; Assert.assertFalse(HttpUtils.hasStreamingScheme(uri)); uri = URI.create("http: Assert.assertFalse(HttpUtils.hasStreamingScheme(uri)); uri = URI.create("ws: Assert.assertFalse(HttpUtils.hasStreamingScheme(uri)); uri = URI.create("sslwse: Assert.assertFalse(HttpUtils.hasStreamingScheme(uri)); uri = URI.create("tcp: Assert.assertTrue(HttpUtils.hasStreamingScheme(uri)); uri = URI.create("ssl: Assert.assertTrue(HttpUtils.hasStreamingScheme(uri)); }
public static boolean hasStreamingScheme(URI uri) { if (uri == null || uri.getScheme() == null) { return false; } final String scheme = uri.getScheme(); return ("tcp".equalsIgnoreCase(scheme) || "ssl".equalsIgnoreCase(scheme)); }
HttpUtils { public static boolean hasStreamingScheme(URI uri) { if (uri == null || uri.getScheme() == null) { return false; } final String scheme = uri.getScheme(); return ("tcp".equalsIgnoreCase(scheme) || "ssl".equalsIgnoreCase(scheme)); } }
HttpUtils { public static boolean hasStreamingScheme(URI uri) { if (uri == null || uri.getScheme() == null) { return false; } final String scheme = uri.getScheme(); return ("tcp".equalsIgnoreCase(scheme) || "ssl".equalsIgnoreCase(scheme)); }  }
HttpUtils { public static boolean hasStreamingScheme(URI uri) { if (uri == null || uri.getScheme() == null) { return false; } final String scheme = uri.getScheme(); return ("tcp".equalsIgnoreCase(scheme) || "ssl".equalsIgnoreCase(scheme)); }  static String getHostDomain(HttpRequestMessage httpRequest); static String getHostAndPort(HttpRequestMessage httpRequest, boolean secure); static String getHostAndPort(String authority, boolean secure); static long parseDateHeader(String header); static String formatDateHeader(long millis); static void fileRequested(IoBufferAllocatorEx<?> allocator, HttpRequestMessage httpRequest,
        HttpResponseMessage httpResponse, File requestFile); static void writeIfModified(HttpAcceptSession httpSession, File requestFile); static IoBufferEx getBufferForFile(IoBufferAllocatorEx<?> allocator, File requestFile); static boolean hasBeenModified(HttpSession session, String etag, File requestFile); static void addLastModifiedHeader(HttpSession session, File requestFile); static String getETagHeaderValue(File requestFile); static void supplyScriptAsHtml(File xdBridgeFile, long startTime, String resourcePath); static void supplyFile(File bridgeFile, long startTime, String resourcePath); static boolean canStream(HttpSession session); static String newSessionId(); static URI getRequestURI(HttpRequestMessage request, IoSession session); static URI getRequestURI(URI requestURI, String hostHeader, IoSession session); static boolean hasCloseHeader(List<String> connectionValues); static URI getTransportURI(HttpRequestMessage request, IoSession session); static boolean isChunked(String transferEncoding); static boolean isChunked(HttpResponseMessage response); static boolean isGzipped(HttpResponseMessage response); static URI getCanonicalURI(URI uri, boolean canonicalizePath); static URI getCanonicalURI(String uriString, boolean canonicalizePath); static String[] getPathComponents(URI uri); static String getAuthenticationTokenFromPath(URI uri); static boolean containsForbiddenHeaders(HttpRequestMessage request, String[] allowedHeaders); static boolean isForbiddenHeader(String header); static void excludeHeaders(HttpRequestMessage request, String[] exclusions); static void restrictHeaders(HttpRequestMessage request, String[] restrictions); static void mergeHeaders(HttpRequestMessage from, HttpRequestMessage to, String[] ignoreHeaders); static void removeValueFromHeaders(HttpRequestMessage request, String[] headerNames, String valueToRemove); static void mergeParameters(HttpRequestMessage from, HttpRequestMessage to); static void mergeCookies(HttpRequestMessage from, HttpRequestMessage to); static String mergeQueryParameters(URI from, String into); static boolean hasStreamingScheme(URI uri); static boolean hasStreamingScheme(String uri); }
HttpUtils { public static boolean hasStreamingScheme(URI uri) { if (uri == null || uri.getScheme() == null) { return false; } final String scheme = uri.getScheme(); return ("tcp".equalsIgnoreCase(scheme) || "ssl".equalsIgnoreCase(scheme)); }  static String getHostDomain(HttpRequestMessage httpRequest); static String getHostAndPort(HttpRequestMessage httpRequest, boolean secure); static String getHostAndPort(String authority, boolean secure); static long parseDateHeader(String header); static String formatDateHeader(long millis); static void fileRequested(IoBufferAllocatorEx<?> allocator, HttpRequestMessage httpRequest,
        HttpResponseMessage httpResponse, File requestFile); static void writeIfModified(HttpAcceptSession httpSession, File requestFile); static IoBufferEx getBufferForFile(IoBufferAllocatorEx<?> allocator, File requestFile); static boolean hasBeenModified(HttpSession session, String etag, File requestFile); static void addLastModifiedHeader(HttpSession session, File requestFile); static String getETagHeaderValue(File requestFile); static void supplyScriptAsHtml(File xdBridgeFile, long startTime, String resourcePath); static void supplyFile(File bridgeFile, long startTime, String resourcePath); static boolean canStream(HttpSession session); static String newSessionId(); static URI getRequestURI(HttpRequestMessage request, IoSession session); static URI getRequestURI(URI requestURI, String hostHeader, IoSession session); static boolean hasCloseHeader(List<String> connectionValues); static URI getTransportURI(HttpRequestMessage request, IoSession session); static boolean isChunked(String transferEncoding); static boolean isChunked(HttpResponseMessage response); static boolean isGzipped(HttpResponseMessage response); static URI getCanonicalURI(URI uri, boolean canonicalizePath); static URI getCanonicalURI(String uriString, boolean canonicalizePath); static String[] getPathComponents(URI uri); static String getAuthenticationTokenFromPath(URI uri); static boolean containsForbiddenHeaders(HttpRequestMessage request, String[] allowedHeaders); static boolean isForbiddenHeader(String header); static void excludeHeaders(HttpRequestMessage request, String[] exclusions); static void restrictHeaders(HttpRequestMessage request, String[] restrictions); static void mergeHeaders(HttpRequestMessage from, HttpRequestMessage to, String[] ignoreHeaders); static void removeValueFromHeaders(HttpRequestMessage request, String[] headerNames, String valueToRemove); static void mergeParameters(HttpRequestMessage from, HttpRequestMessage to); static void mergeCookies(HttpRequestMessage from, HttpRequestMessage to); static String mergeQueryParameters(URI from, String into); static boolean hasStreamingScheme(URI uri); static boolean hasStreamingScheme(String uri); static Map<String, List<String>> EMPTY_HEADERS; }