public abstract class StreamObject extends Object implements IFSSHTTPBSerializable
| Modifier | Constructor and Description | 
|---|---|
protected  | 
StreamObject(StreamObjectTypeHeaderStart streamObjectType)
Initializes a new instance of the StreamObject class. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
deserializeFromByteArray(StreamObjectHeaderStart header,
                        byte[] byteArray,
                        int startIndex)
Used to return the length of this element. 
 | 
protected abstract void | 
deserializeItemsFromByteArray(byte[] byteArray,
                             AtomicInteger currentIndex,
                             int lengthOfItems)
De-serialize items from byte array. 
 | 
static Set<StreamObjectTypeHeaderStart> | 
getCompoundTypes()
Gets the StreamObjectTypeHeaderStart 
 | 
static <T extends StreamObject> | 
getCurrent(byte[] byteArray,
          AtomicInteger index,
          Class<T> clazz)
Get current stream object. 
 | 
static Map<StreamObjectTypeHeaderStart,Class> | 
getStreamObjectTypeMapping()
Gets the StreamObjectTypeMapping 
 | 
static StreamObject | 
parseStreamObject(StreamObjectHeaderStart header,
                 byte[] byteArray,
                 AtomicInteger index)
Parse stream object from byte array. 
 | 
protected abstract int | 
serializeItemsToByteList(List<Byte> byteList)
Serialize items to byte list. 
 | 
List<Byte> | 
serializeToByteList()
Serialize item to byte list. 
 | 
static <T extends StreamObject> | 
tryGetCurrent(byte[] byteArray,
             AtomicInteger index,
             AtomicReference<T> streamObject,
             Class<T> clazz)
Try to get current object, true will returned if success. 
 | 
protected StreamObject(StreamObjectTypeHeaderStart streamObjectType)
streamObjectType - The instance of StreamObjectTypeHeaderStart.public static Set<StreamObjectTypeHeaderStart> getCompoundTypes()
public static Map<StreamObjectTypeHeaderStart,Class> getStreamObjectTypeMapping()
public static <T extends StreamObject> T getCurrent(byte[] byteArray, AtomicInteger index, Class<T> clazz) throws TikaException, IOException
byteArray - The byte array which contains message.index - The position where to start.TikaExceptionIOExceptionpublic static StreamObject parseStreamObject(StreamObjectHeaderStart header, byte[] byteArray, AtomicInteger index) throws IOException, TikaException
header - The instance of StreamObjectHeaderStart.byteArray - The byte array.index - The position where to start.IOExceptionTikaExceptionpublic static <T extends StreamObject> boolean tryGetCurrent(byte[] byteArray, AtomicInteger index, AtomicReference<T> streamObject, Class<T> clazz) throws TikaException, IOException
byteArray - The byte array.index - The position where to start.streamObject - The instance that want to get.TikaExceptionIOExceptionpublic List<Byte> serializeToByteList() throws IOException, TikaException
serializeToByteList in interface IFSSHTTPBSerializableIOExceptionTikaExceptionpublic int deserializeFromByteArray(StreamObjectHeaderStart header, byte[] byteArray, int startIndex) throws IOException, TikaException
header - Then instance of StreamObjectHeaderStart.byteArray - The byte liststartIndex - The position where to start.IOExceptionTikaExceptionprotected abstract int serializeItemsToByteList(List<Byte> byteList) throws IOException, TikaException
byteList - The byte list need to serialized.IOExceptionTikaExceptionprotected abstract void deserializeItemsFromByteArray(byte[] byteArray,
                                                      AtomicInteger currentIndex,
                                                      int lengthOfItems)
                                               throws TikaException,
                                                      IOException
byteArray - The byte array which contains response message.currentIndex - The index special where to start.lengthOfItems - The length of items.TikaExceptionIOExceptionCopyright © 2007–2021 The Apache Software Foundation. All rights reserved.