activemq-cpp-3.4.0

src/main/decaf/io/PushbackInputStream.h

Go to the documentation of this file.
00001 /*
00002  * Licensed to the Apache Software Foundation (ASF) under one or more
00003  * contributor license agreements.  See the NOTICE file distributed with
00004  * this work for additional information regarding copyright ownership.
00005  * The ASF licenses this file to You under the Apache License, Version 2.0
00006  * (the "License"); you may not use this file except in compliance with
00007  * the License.  You may obtain a copy of the License at
00008  *
00009  *     http://www.apache.org/licenses/LICENSE-2.0
00010  *
00011  * Unless required by applicable law or agreed to in writing, software
00012  * distributed under the License is distributed on an "AS IS" BASIS,
00013  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
00014  * See the License for the specific language governing permissions and
00015  * limitations under the License.
00016  */
00017 
00018 #ifndef _DECAF_IO_PUSHBACKINPUTSTREAM_H_
00019 #define _DECAF_IO_PUSHBACKINPUTSTREAM_H_
00020 
00021 #include <decaf/util/Config.h>
00022 
00023 #include <decaf/io/InputStream.h>
00024 #include <decaf/io/FilterInputStream.h>
00025 
00026 namespace decaf {
00027 namespace io {
00028 
00042     class PushbackInputStream : public FilterInputStream {
00043     private:
00044 
00045         unsigned char* buffer;
00046         int bufferSize;
00047         int pos;
00048 
00049     private:
00050 
00051         PushbackInputStream( const PushbackInputStream& );
00052         PushbackInputStream& operator= ( const PushbackInputStream& );
00053 
00054     public:
00055 
00065         PushbackInputStream( InputStream* stream, bool own = false );
00066 
00080         PushbackInputStream( InputStream* stream, int bufSize, bool own = false );
00081 
00082         virtual ~PushbackInputStream();
00083 
00094         void unread( unsigned char value );
00095 
00110         void unread( const unsigned char* buffer, int size );
00111 
00130         void unread( const unsigned char* buffer, int size, int offset, int length );
00131 
00138         virtual int available() const;
00139 
00147         virtual long long skip( long long num );
00148 
00154         virtual void mark( int readLimit );
00155 
00161         virtual void reset();
00162 
00168         virtual bool markSupported() const {
00169             return false;
00170         }
00171 
00172     protected:
00173 
00174         virtual int doReadByte();
00175 
00176         virtual int doReadArrayBounded( unsigned char* buffer, int size, int offset, int length );
00177 
00178     };
00179 
00180 }}
00181 
00182 #endif /* _DECAF_IO_PUSHBACKINPUTSTREAM_H_ */