Package java.io

Examples of java.io.FilterInputStream

412
413
414
415
416
417
418
419
420
421
422
                                          ExtensionRegistry extensionRegistry)
                                          throws IOException {
      final int size = CodedInputStream.readRawVarint32(input);

      // A stream which will not read more than |size| bytes.
      InputStream limitedInput = new FilterInputStream(input) {
        int limit = size;

        @Override
        public int available() throws IOException {
          return Math.min(super.available(), limit);
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
    public InputStream getInputStream()
        throws java.io.IOException
    {    
        checkConnection();
        if (!_urlString.endsWith("!/"))
            return new FilterInputStream(super.getInputStream())
            {
                public void close() throws IOException {this.in=IO.getClosedStream();}
            };

        URL url = new URL(_urlString.substring(4,_urlString.length()-2));     
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
          } else {
            filename = "version-forge-nohydra.json";
            mod="-forge-nohydra";
          }

          version_json = new FilterInputStream( Installer.class.getResourceAsStream(filename) ) {
            public int read(byte[] buff) throws IOException {
              int ret = in.read(buff);
              if( ret > 0 ) {
                String s = new String( buff,0, ret, "UTF-8");
                s = s.replace("$FORGE_VERSION", (String)forgeVersion.getSelectedItem());
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
    protected Iterator getResponseHeaders(String name) throws IOException {
        return Collections.EMPTY_LIST.iterator();
    }

    protected InputStream getResponseInputStream() throws IOException {
        return new FilterInputStream(socket.getInputStream()) {

            @Override
            public void close() throws IOException {
                // don't close the socket
                socket.shutdownInput();
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
    protected Iterator getRequestHeaders(String name) throws IOException {
        return Collections.EMPTY_LIST.iterator();
    }

    protected InputStream getRequestInputStream() throws IOException {
        return new FilterInputStream(socket.getInputStream()) {

            @Override
            public void close() throws IOException {
                // don't close the socket
                socket.shutdownInput();
View Full Code Here
685
686
687
688
689
690
691
692
693
694
695
                InputStream in = rs.getBinaryStream(1);
                /**
                 * return an InputStream wrapper in order to
                 * close the ResultSet when the stream is closed
                 */
                return new FilterInputStream(in) {
                    public void close() throws IOException {
                        super.close();
                        // close ResultSet
                        closeResultSet(rs);
                    }
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
                    fileObject.getName(),
                    new Long(filePointer)
                });
            }
        }
        dis = new DataInputStream(new FilterInputStream(mis)
        {
            @Override
            public int read() throws IOException
            {
                int ret = super.read();
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
            return dis;
        }

        // FtpClient client = fileSystem.getClient();
        mis = fileObject.getInputStream(filePointer);
        dis = new DataInputStream(new FilterInputStream(mis)
        {
            @Override
            public int read() throws IOException
            {
                int ret = super.read();
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
            return dis;
        }

        // FtpClient client = fileSystem.getClient();
        mis = fileObject.getInputStream(filePointer);
        dis = new DataInputStream(new FilterInputStream(mis)
        {
            @Override
            public int read() throws IOException
            {
                int ret = super.read();
View Full Code Here
679
680
681
682
683
684
685
686
687
688
689
                InputStream in = rs.getBinaryStream(1);
                /**
                 * return an InputStream wrapper in order to
                 * close the ResultSet when the stream is closed
                 */
                return new FilterInputStream(in) {
                    public void close() throws IOException {
                        super.close();
                        // close ResultSet
                        closeResultSet(rs);
                    }
View Full Code Here
TOP

Related Classes of java.io.FilterInputStream

  • co.cask.cdap.common.lang.jar.BundleJarUtil
  • co.cask.tigon.lang.jar.BundleJarUtil
  • com.alibaba.antx.util.scanner.ZipScanner
  • com.bj58.argo.thirdparty.jetty.MultiPartInputStreamParser
  • com.esotericsoftware.kryo.compress.StreamCompressor
  • com.facebook.presto.jdbc.internal.jetty.util.MultiPartInputStreamParser
  • com.facebook.presto.jdbc.internal.jetty.util.resource.JarResource
  • com.google.api.client.googleapis.batch.BatchUnparsedResponse
  • com.google.common.io.ByteStreamsTest
  • com.google.common.io.MultiInputStreamTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.