Java Stream类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中lotus.domino.Stream类的典型用法代码示例。如果您正苦于以下问题：Java Stream类的具体用法？Java Stream怎么用？Java Stream使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Stream类属于lotus.domino包，在下文中一共展示了Stream类的14个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: processJava2Domino

import lotus.domino.Stream; //导入依赖的package包/类
public void processJava2Domino(Document docCurrent, Object objCurrent, String strNotesField, String strJavaField, HashMap<String, Object> addValues) {
	try {

		MimeMultipart body = getValue(objCurrent, strJavaField);

		Stream stream = docCurrent.getParentDatabase().getParent().createStream();
		if (body != null)
			stream.writeText(body.getHTML());
		else
			return;

		MIMEEntity entity = docCurrent.getMIMEEntity(strNotesField);
		if (entity == null) {
			docCurrent.removeItem(strNotesField);
			entity = docCurrent.createMIMEEntity(strNotesField);
		}
		entity.setContentFromText(stream, "text/html;charset=UTF-8", 1725);
		stream.close();
		// docCurrent.replaceItemValue(strNotesField, strValue);

	} catch (Exception e) {
		e.printStackTrace();
	}

}

开发者ID:OpenNTF，项目名称:myWebGate-Scrum，代码行数:26，代码来源:MimeMultipartBinder.java

示例2: processJava2Domino

import lotus.domino.Stream; //导入依赖的package包/类
public void processJava2Domino(Document docCurrent, Object objCurrent,
		String strNotesField, String strJavaField,
		HashMap<String, Object> addValues) {
	try {
		
		MimeMultipart body = getValue(objCurrent, strJavaField);
		
		Stream stream = docCurrent.getParentDatabase().getParent().createStream();
		stream.writeText(body.getHTML());
		
		MIMEEntity entity = docCurrent.getMIMEEntity(strNotesField);
		if(entity == null)
			entity = docCurrent.createMIMEEntity(strNotesField);
		
		entity.setContentFromText(stream,"text/html;charset=UTF-8", 1725);
		stream.close();
		//docCurrent.replaceItemValue(strNotesField, strValue);

	} catch (Exception e) {
		e.printStackTrace();
	}

}

开发者ID:OpenNTF，项目名称:Nagios4DominoIntegration，代码行数:24，代码来源:MimeMultipartBinder.java

示例3: MIMEBufferedInputStream

import lotus.domino.Stream; //导入依赖的package包/类
public MIMEBufferedInputStream(final Stream is, final int size) {
	try {
		this.is = is;
		this.buffer = new byte[size];
		this.length = is.getBytes();
	} catch (NotesException ne) {
		DominoUtils.handleException(ne);
		throw new RuntimeException(MIMEBufferedInputStream.class.getName() + " Constructor Failure");
	}
	//			instanceCount++;
	//			if (++instanceCount % 1000 == 0) {
	//				System.out.println("Created " + instanceCount + " MIMEInputStream objects...");
	//			}
}

开发者ID:OpenNTF，项目名称:org.openntf.domino，代码行数:15，代码来源:Streams.java

示例4: getStreamBytes

import lotus.domino.Stream; //导入依赖的package包/类
public static int getStreamBytes(final Stream stream) {
	try {
		return stream.getBytes();
	} catch (NotesException ne) {
		DominoUtils.handleException(ne);
	}
	return 0;
}

开发者ID:OpenNTF，项目名称:org.openntf.domino，代码行数:9，代码来源:Streams.java

示例5: readerToNotesStream

import lotus.domino.Stream; //导入依赖的package包/类
private static void readerToNotesStream(Stream stream, Reader reader) throws IOException, NotesException {
    BufferedReader br = new BufferedReader(reader);
    String line = br.readLine();
    while ( line != null ) {
        stream.writeText(line);
        stream.writeText("\r\n"); //$NON-NLS-1$
        line = br.readLine();
    }
}

开发者ID:OpenNTF，项目名称:XPagesExtensionLibrary，代码行数:10，代码来源:MimeMessageParser.java

示例6: inputStreamToNotesStream

import lotus.domino.Stream; //导入依赖的package包/类
private static void inputStreamToNotesStream(Stream stream, InputStream is) throws IOException, NotesException {
    
    int ch = is.read();
    while ( ch != -1 ) {
        byte b[] = new byte[1];
        b[0] = (byte)ch;
        stream.write(b);
        ch = is.read();
    }
}

开发者ID:OpenNTF，项目名称:XPagesExtensionLibrary，代码行数:11，代码来源:MimeMessageParser.java

示例7: saveState

import lotus.domino.Stream; //导入依赖的package包/类
/**
 * Save state. Imported from org.openntf.domino
 * 
 * @param object
 *            the object
 * @param doc
 *            the doc
 * @param itemName
 *            the item name
 * @param compress
 *            the compress
 * @throws Throwable
 *             the throwable
 */
public static void saveState(Serializable object, Document doc, String itemName, boolean compress, Map<String, String> headers) throws Throwable {
	Session session=doc.getParentDatabase().getParent();
	boolean convertMime = session.isConvertMime();
	session.setConvertMime(false);

	ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
	ObjectOutputStream objectStream = compress ? new ObjectOutputStream(new GZIPOutputStream(byteStream)) : new ObjectOutputStream(
			byteStream);
	String contentType = null;

	// Prefer externalization if available
	if(object instanceof Externalizable) {
		((Externalizable)object).writeExternal(objectStream);
		contentType = "application/x-java-externalized-object";
	} else {
		objectStream.writeObject(object);
		contentType = "application/x-java-serialized-object";
	}

	objectStream.flush();
	objectStream.close();

	Stream mimeStream = session.createStream();
	MIMEEntity previousState = doc.getMIMEEntity(itemName);
	MIMEEntity entity = previousState == null ? doc.createMIMEEntity(itemName) : previousState;
	ByteArrayInputStream byteIn = new ByteArrayInputStream(byteStream.toByteArray());
	mimeStream.setContents(byteIn);
	entity.setContentFromBytes(mimeStream, contentType, MIMEEntity.ENC_NONE);
	MIMEHeader contentEncoding = entity.getNthHeader("Content-Encoding");
	if (compress) {
		if (contentEncoding == null) {
			contentEncoding = entity.createHeader("Content-Encoding");
		}
		contentEncoding.setHeaderVal("gzip");
		contentEncoding.recycle();
	} else {
		if (contentEncoding != null) {
			contentEncoding.remove();
			contentEncoding.recycle();
		}
	}
	MIMEHeader javaClass = entity.getNthHeader("X-Java-Class");
	if (javaClass == null) {
		javaClass = entity.createHeader("X-Java-Class");
	}
	javaClass.setHeaderVal(object.getClass().getName());
	javaClass.recycle();

	if(headers != null) {
		for(Map.Entry<String, String> entry : headers.entrySet()) {
			MIMEHeader paramHeader = entity.getNthHeader(entry.getKey());
			if(paramHeader == null) {
				paramHeader = entity.createHeader(entry.getKey());
			}
			paramHeader.setHeaderVal(entry.getValue());
			paramHeader.recycle();
		}
	}

	entity.recycle();
	mimeStream.recycle();

	session.setConvertMime(convertMime);
}

开发者ID:sbasegmez，项目名称:Blogged，代码行数:79，代码来源:DevelopiUtils.java

示例8: processJava2Domino

import lotus.domino.Stream; //导入依赖的package包/类
public MimeMultipart[] processJava2Domino(Document docCurrent, Object objCurrent, Definition def) {
	MimeMultipart[] mpRC = new MimeMultipart[2];
	Logger log = LoggerFactory.getLogger(this.getClass().getCanonicalName());
	try {

		MimeMultipart oldBody = getRawValueFromStore(docCurrent, def.getNotesField());
		MimeMultipart body = getValue(objCurrent, def.getJavaField());
		mpRC[0] = oldBody;
		mpRC[1] = body;
		log.fine("oldBody = " + oldBody);
		log.fine("body = " + body);
		Stream stream = docCurrent.getParentDatabase().getParent().createStream();
		if (body != null)
			stream.writeText(body.getHTML());
		else
			return null;

		MIMEEntity entity = docCurrent.getMIMEEntity(def.getNotesField());
		log.info("entity = " + entity);
		if (entity == null) {
			docCurrent.removeItem(def.getNotesField());
			log.info("creating Entity for " + def.getNotesField());
			entity = docCurrent.createMIMEEntity(def.getNotesField());
			log.info("new entity created");
		}
		stream.setPosition(0);
		entity.setContentFromText(stream, "text/html;charset=UTF-8", 1725);
		stream.close();
		log.info("done");

	} catch (Exception e) {
		LoggerFactory.logWarning(this.getClass(), "Error during processJava2Domino", e);
		throw new XPTRuntimeException("Error during processJava2Domino", e);
	}
	return mpRC;

}

开发者ID:OpenNTF，项目名称:XPagesToolkit，代码行数:38，代码来源:MimeMultipartBinder.java

示例9: getContentsAsText

import lotus.domino.Stream; //导入依赖的package包/类
private String getContentsAsText(MIMEEntity child, Session sesCurrent) throws NotesException {
	Stream stream = sesCurrent.createStream();
	child.getContentAsText(stream, true);
	stream.setPosition(0);
	String str = stream.readText();
	stream.recycle();
	return str;
}

开发者ID:OpenNTF，项目名称:XPagesToolkit，代码行数:9，代码来源:MimeMultipartBinder.java

示例10: readStream

import lotus.domino.Stream; //导入依赖的package包/类
public static byte[] readStream(final Stream stream, final int length) {
	try {
		return stream.read(length);
	} catch (NotesException ne) {
		DominoUtils.handleException(ne);
		return null;
	}
}

开发者ID:OpenNTF，项目名称:org.openntf.domino，代码行数:9，代码来源:Streams.java

示例11: getStreamPosition

import lotus.domino.Stream; //导入依赖的package包/类
public static int getStreamPosition(final Stream stream) {
	try {
		return stream.getPosition();
	} catch (NotesException ne) {
		DominoUtils.handleException(ne);
		return -1;
	}
}

开发者ID:OpenNTF，项目名称:org.openntf.domino，代码行数:9，代码来源:Streams.java

示例12: setStreamPosition

import lotus.domino.Stream; //导入依赖的package包/类
public static boolean setStreamPosition(final Stream stream, final int position) {
	try {
		stream.setPosition(position);
		return true;
	} catch (NotesException ne) {
		DominoUtils.handleException(ne);
		return false;
	}
}

开发者ID:OpenNTF，项目名称:org.openntf.domino，代码行数:10，代码来源:Streams.java

示例13: processJava2Domino

import lotus.domino.Stream; //导入依赖的package包/类
public Object[] processJava2Domino(Document docCurrent, Object objCurrent, Definition def) {
	Object[] objRC = new Object[2];
	try {
		Object oldBody = getRawValueFromStore(docCurrent, def.getNotesField());
		Object body = getValue(objCurrent, def.getJavaField());
		objRC[0] = oldBody;
		objRC[1] = body;
		Session session = docCurrent.getParentDatabase().getParent();

		boolean convertMime = session.isConvertMime();
		session.setConvertMime(false);

		ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
		ObjectOutputStream objectStream = new ObjectOutputStream(new GZIPOutputStream(byteStream));
		objectStream.writeObject(body);
		objectStream.flush();
		objectStream.close();

		MIMEEntity entity = null;
		MIMEEntity previousState = docCurrent.getMIMEEntity(def.getNotesField());
		if (previousState == null) {
			entity = docCurrent.createMIMEEntity(def.getNotesField());
		} else {
			entity = previousState;
		}
		Stream mimeStream = session.createStream();
		ByteArrayInputStream byteIn = new ByteArrayInputStream(byteStream.toByteArray());
		mimeStream.setContents(byteIn);
		entity.setContentFromBytes(mimeStream, "application/x-java-serialized-object", MIMEEntity.ENC_NONE);

		MIMEHeader header = entity.getNthHeader("Content-Encoding");
		if (header == null) {
			header = entity.createHeader("Content-Encoding");
		}
		header.setHeaderVal("gzip");

		header.recycle();
		entity.recycle();
		mimeStream.recycle();

		session.setConvertMime(convertMime);

	} catch (Exception e) {
		LoggerFactory.logWarning(getClass(), "Error during processJava2Domino", e);
	}
	return objRC;

}

开发者ID:OpenNTF，项目名称:XPagesToolkit，代码行数:49，代码来源:ObjectBinder.java

示例14: get

import lotus.domino.Stream; //导入依赖的package包/类
public static InputStream get(final Stream source) {
	return source != null ? new MIMEBufferedInputStream(source) : null;
}

开发者ID:OpenNTF，项目名称:org.openntf.domino，代码行数:4，代码来源:Streams.java

注：本文中的lotus.domino.Stream类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。