src/main/java/org/apache/james/mime4j/BufferingInputStream.java

   1 /****************************************************************
   2  * Licensed to the Apache Software Foundation (ASF) under one   *
   3  * or more contributor license agreements.  See the NOTICE file *
   4  * distributed with this work for additional information        *
   5  * regarding copyright ownership.  The ASF licenses this file   *
   6  * to you under the Apache License, Version 2.0 (the            *
   7  * "License"); you may not use this file except in compliance   *
   8  * with the License.  You may obtain a copy of the License at   *
   9  *                                                              *
  10  *   http://www.apache.org/licenses/LICENSE-2.0                 *
  11  *                                                              *
  12  * Unless required by applicable law or agreed to in writing,   *
  13  * software distributed under the License is distributed on an  *
  14  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY       *
  15  * KIND, either express or implied.  See the License for the    *
  16  * specific language governing permissions and limitations      *
  17  * under the License.                                           *
  18  ****************************************************************/
  19
  20 package org.apache.james.mime4j;
  21
  22 import java.io.IOException;
  23 import java.io.InputStream;
  24
  25 /**
  26  * Implementation of {@link InputStream} backed by an {@link InputBuffer} instance.
  27  */
  28 public class BufferingInputStream extends InputStream {
  29
  30     private final InputBuffer buffer;
  31
  32     public BufferingInputStream(final InputBuffer buffer) {
  33         super();
  34         this.buffer = buffer;
  35     }
  36
  37     public void close() throws IOException {
  38         this.buffer.closeStream();
  39     }
  40
  41     public boolean markSupported() {
  42         return false;
  43     }
  44
  45     public int read() throws IOException {
  46         return this.buffer.read();
  47     }
  48
  49     public int read(byte[] b, int off, int len) throws IOException {
  50         return this.buffer.read(b, off, len);
  51     }
  52
  53 }