import com.sun.xml.internal.messaging.saaj.util.ByteInputStream; //导入依赖的package包/类
public ZipFullEntry(ZipInputStream stream, ZipEntry e, boolean isParentJarFile) {
    insideJar = isParentJarFile;
    entry = e;
    contentsGetter = () -> {
        try {
            long size = e.getSize();
            // Note: This will fail to properly read 2gb+ files, but we have other problems if that's in this JAR file.
            if (size <= 0) {
                return Optional.empty();
            }
            byte[] buffer = new byte[(int) size];
            stream.read(buffer);
            return Optional.of(new ByteInputStream(new byte[(int) e.getSize()], buffer.length));
        } catch (IOException ex) {
            Logger.getLogger(ZipFullEntry.class.getName()).log(Level.SEVERE, null, ex);
            return Optional.empty();
        }
    };
}
 

import com.sun.xml.internal.messaging.saaj.util.ByteInputStream; //导入依赖的package包/类
public static String uncompressString(byte[] bytes) {
	try {
		ByteInputStream bis = new ByteInputStream(bytes, bytes.length);
		ZipInputStream zis = new ZipInputStream(bis);
		ZipEntry entry = zis.getNextEntry();
		int byteSize = 5000, len = 0;
		byte[] contentBytes = new byte[byteSize];
		ByteArrayOutputStream bufStream = new ByteArrayOutputStream();
		if ( entry != null ) {
			while ( (len = zis.read(contentBytes)) != -1 ) {
				bufStream.write(contentBytes, 0, len);
			}
			String content = new String(bufStream.toByteArray(), "utf8");
			return content;
		}
	} catch (IOException e) {
		logger.warn("Failed to unzip string.", e);
	}
	return null;
}
 

import com.sun.xml.internal.messaging.saaj.util.ByteInputStream; //导入依赖的package包/类
public static String uncompressStringZlib(byte[] bytes) {
	try {
		ByteInputStream bis = new ByteInputStream(bytes, bytes.length);
		InflaterInputStream zis = new InflaterInputStream(bis);
		int byteSize = 5000, len = 0;
		byte[] contentBytes = new byte[byteSize];
		ByteArrayOutputStream bufStream = new ByteArrayOutputStream();
		while ( (len = zis.read(contentBytes)) != -1 ) {
			bufStream.write(contentBytes, 0, len);
		}
		String content = new String(bufStream.toByteArray(), "utf8");
		return content;
	} catch (IOException e) {
		logger.warn("Failed to unzip string.", e);
	}
	return null;
}
 

import com.sun.xml.internal.messaging.saaj.util.ByteInputStream; //导入依赖的package包/类
@BeforeClass
void insertBinaryEntry() throws IOException {
    bindDummyContext();
    try {
        // Create a dummy binary entry for testing file creation
        BinaryInfo binaryInfo = binaryStore.addBinary(new ByteInputStream(new byte[]{1, 2, 3}, 3));
        sha1 = binaryInfo.getSha1();
    } finally {
        unbindDummyContext();
    }
}
 

import com.sun.xml.internal.messaging.saaj.util.ByteInputStream; //导入依赖的package包/类
private Clip getClip() {
    Clip c = null;
    try {
        AudioInputStream ais=AudioSystem.getAudioInputStream(
                new ByteInputStream(samples,samples.length));
        c = (Clip) AudioSystem.getLine(new Line.Info(Clip.class));
        c.open(ais);
    } catch (Exception e) {
        e.printStackTrace();
    }
    return c;
}
 

import com.sun.xml.internal.messaging.saaj.util.ByteInputStream; //导入依赖的package包/类
public InputStream getContentAsStream() throws IOException {
    if (source != null) {
        InputStream is = null;

        // Allow message to be transcode if so requested
        if (source instanceof StreamSource && !isFastInfoset()) {
            is = ((StreamSource) source).getInputStream();
        }
        else if (FastInfosetReflection.isFastInfosetSource(source) &&
            isFastInfoset())
        {
            try {
                // InputStream is = source.getInputStream()
                is = FastInfosetReflection.FastInfosetSource_getInputStream(source);
            }
            catch (Exception e) {
                throw new IOException(e.toString());
            }
        }

        if (is != null) {
            if (lazyContentLength) {
                return is;
            }
            if (!(is instanceof ByteInputStream)) {
                log.severe("SAAJ0546.soap.stream.incorrect.type");
                throw new IOException("Internal error: stream not of the right type");
            }
            return (ByteInputStream) is;
        }
        // need to do something here for reader...
        // for now we'll see if we can fallback...
    }

    ByteOutputStream b = new ByteOutputStream();

    Envelope env = null;

    try {
        env = (Envelope) getEnvelope();
        env.output(b, isFastInfoset());
    }
    catch (SOAPException soapException) {
        log.severe("SAAJ0547.soap.cannot.externalize");
        throw new SOAPIOException(
        "SOAP exception while trying to externalize: ",
        soapException);
    }

    return b.newInputStream();
}
 

import com.sun.xml.internal.messaging.saaj.util.ByteInputStream; //导入依赖的package包/类
@Override
public InputStream getInputStream() throws IOException {
	byte[] bytes = getContent().toString().getBytes();
	return new ByteInputStream(bytes, bytes.length);
}
 

import com.sun.xml.internal.messaging.saaj.util.ByteInputStream; //导入依赖的package包/类
public void received(Connection connection, Object object) {
	if (object instanceof CameraMessage) {
		CameraMessage message = (CameraMessage) object;
		CameraConnection cameraConnection = (CameraConnection) connection;
		switch (message.messageId) {
			case UPDATE_CAR:
				UpdateCarMessage updateCarMsg = (UpdateCarMessage) message;
				
				if (!cameraConnection.isValidUpdateCarMessage(updateCarMsg.seqNr))
					break;
				
				_moderator.updateCar(updateCarMsg.carId, updateCarMsg.posX, updateCarMsg.posY,
						updateCarMsg.direction);
				break;
			case CAR_DETECTED:
				CarDetectedMessage carDetectedMsg = (CarDetectedMessage) message;
				
				// get the car image
				BufferedImage carImage = null;
				if (carDetectedMsg.image != null && carDetectedMsg.image.length > 0) {
					try {
						InputStream in = new ByteInputStream(carDetectedMsg.image,
								carDetectedMsg.image.length);
						carImage = ImageIO.read(in);
						in.close();
					} catch (IOException e) {
						_logger.error("Exception caught while reading car image!", e);
					}
					
				} else {
					_logger.error("No image received for car with id: {}", carDetectedMsg.carId);
				}
				
				if (carImage != null) {
					
					Car<Player> car = new Car<Player>(carDetectedMsg.carId, new Position(
							carDetectedMsg.posX, carDetectedMsg.posY), new Direction(
							carDetectedMsg.direction), carImage);
					_moderator.carDetected(car);
				}
				
				break;
			case CONFIGURE_MAP:
				ConfigureMapMessage configureMapMsg = (ConfigureMapMessage) message;
				_moderator.configureMap(configureMapMsg.sizeX, configureMapMsg.sizeY);
				break;
			case DETECTION_FINISHED:
				_moderator.detectionFinished();
				break;
			default:
				_logger.warn("Camera message with id: {} not known!", message.messageId);
				break;
		}
	} else if (object instanceof FrameworkMessage.KeepAlive) {
		// _logger.debug("Received Camera keepAlive ...");
	}
}