import org.apache.cassandra.streaming.StreamReader; //导入依赖的package包/类
public IncomingFileMessage deserialize(ReadableByteChannel in, int version, StreamSession session) throws IOException
{
    DataInputStream input = new DataInputStream(Channels.newInputStream(in));
    FileMessageHeader header = FileMessageHeader.serializer.deserialize(input, version);
    StreamReader reader = header.compressionInfo == null ? new StreamReader(header, session)
            : new CompressedStreamReader(header, session);

    try
    {
        return new IncomingFileMessage(reader.read(in), header);
    }
    catch (Throwable t)
    {
        JVMStabilityInspector.inspectThrowable(t);
        session.doRetry(header, t);
        return null;
    }
}
 

import org.apache.cassandra.streaming.StreamReader; //导入依赖的package包/类
public FileMessage deserialize(ReadableByteChannel in, int version, StreamSession session) throws IOException
{
    DataInputStream input = new DataInputStream(Channels.newInputStream(in));
    FileMessageHeader header = FileMessageHeader.serializer.deserialize(input, version);
    StreamReader reader = header.compressionInfo == null ? new StreamReader(header, session)
                                  : new CompressedStreamReader(header, session);

    try
    {
        return new FileMessage(reader.read(in), header);
    }
    catch (Throwable e)
    {
        session.doRetry(header, e);
        return null;
    }
}
 

import org.apache.cassandra.streaming.StreamReader; //导入依赖的package包/类
@SuppressWarnings("resource")
public IncomingFileMessage deserialize(ReadableByteChannel in, int version, StreamSession session) throws IOException
{
    DataInputPlus input = new DataInputStreamPlus(Channels.newInputStream(in));
    FileMessageHeader header = FileMessageHeader.serializer.deserialize(input, version);
    StreamReader reader = !header.isCompressed() ? new StreamReader(header, session)
            : new CompressedStreamReader(header, session);

    try
    {
        return new IncomingFileMessage(reader.read(in), header);
    }
    catch (Throwable t)
    {
        JVMStabilityInspector.inspectThrowable(t);
        throw t;
    }
}
 

import org.apache.cassandra.streaming.StreamReader; //导入依赖的package包/类
public IncomingFileMessage deserialize(ReadableByteChannel in, int version, StreamSession session) throws IOException
{
    DataInputStream input = new DataInputStream(Channels.newInputStream(in));
    FileMessageHeader header = FileMessageHeader.serializer.deserialize(input, version);
    StreamReader reader = header.compressionInfo == null ? new StreamReader(header, session)
            : new CompressedStreamReader(header, session);

    try
    {
        return new IncomingFileMessage(reader.read(in), header);
    }
    catch (Throwable e)
    {
        session.doRetry(header, e);
        return null;
    }
}