Package com.caucho.vfs

Examples of com.caucho.vfs.ReadStream.writeToStream()

1259
1260
1261
1262
1263
1264
1265
1266
1267
1268
1269
    OutputStream os = res.getOutputStream();
    InputStream is = _path.openRead(pathInfo, req, app);
    ReadStream rs = Vfs.openRead(is);
    try {
      rs.writeToStream(os);
    } finally {
      rs.close();
    }
  }
View Full Code Here
628
629
630
631
632
633
634
635
636
637
638
      try {
        is = cache.getPath().openRead();
        is.skip(first);

        os = res.getOutputStream();
        is.writeToStream(os, (int) (last - first + 1));
      } finally {
        if (is != null)
          is.close();
      }
View Full Code Here
246
247
248
249
250
251
252
253
254
255
256
      try {
        hasStatus = parseHeaders(req, res, rs);

        OutputStream out = res.getOutputStream();

        rs.writeToStream(out);
      } finally {
        try {
          rs.close();
        } catch (Throwable e) {
          log.log(Level.FINER, e.toString(), e);
View Full Code Here
906
907
908
909
910
911
912
913
914
915
916
        try {
          ReadStream is = ts.openRead();

          try {
            is.writeToStream(_os);
          } finally {
            is.close();
          }
        } catch (IOException e) {
          e.printStackTrace();
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
    throws IOException
  {
    ReadStream stream = path.openRead();
   
    try {
      stream.writeToStream(os);
    } finally {
      stream.close();
    }
  }
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
    int len;

    Object obj = call.getArgObject(0, length);
    if (obj instanceof ReadStream) {
      ReadStream is = (ReadStream) obj;
      is.writeToStream(os);
    }
    else if (obj instanceof ReadWritePair) {
      ((ReadWritePair) obj).getReadStream().writeToStream(os);
    }
    else if (obj instanceof InputStream) {
View Full Code Here
1258
1259
1260
1261
1262
1263
1264
1265
1266
1267
1268
    OutputStream os = res.getOutputStream();
    InputStream is = _path.openRead(pathInfo, req, app);
    ReadStream rs = Vfs.openRead(is);
    try {
      rs.writeToStream(os);
    } finally {
      rs.close();
    }
  }
View Full Code Here
246
247
248
249
250
251
252
253
254
255
256
      try {
  hasStatus = parseHeaders(req, res, rs);

  OutputStream out = res.getOutputStream();

  rs.writeToStream(out);
      } finally {
  try {
    rs.close();
  } catch (Throwable e) {
    log.log(Level.FINER, e.toString(), e);
View Full Code Here
509
510
511
512
513
514
515
516
517
518
519
      try {
        is = cache.getPath().openRead();
        is.skip(first);

        os = res.getOutputStream();
        is.writeToStream(os, (int) (last - first + 1));
      } finally {
        if (is != null)
          is.close();
      }
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
    throws IOException
  {
    ReadStream stream = path.openRead();
   
    try {
      stream.writeToStream(os);
    } finally {
      stream.close();
    }
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.