|
Ant example source code file (P4OutputStream.java)
The P4OutputStream.java source code/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * */ package org.apache.tools.ant.taskdefs.optional.perforce; import java.io.OutputStream; import java.io.ByteArrayOutputStream; import java.io.IOException; /** * heavily inspired from LogOutputStream * this stream class calls back the P4Handler on each line of stdout or stderr read */ public class P4OutputStream extends OutputStream { private P4Handler handler; private ByteArrayOutputStream buffer = new ByteArrayOutputStream(); private boolean skip = false; /** * creates a new P4OutputStream for a P4Handler * @param handler the handler which will process the streams */ public P4OutputStream(P4Handler handler) { this.handler = handler; } /** * Write the data to the buffer and flush the buffer, if a line * separator is detected. * * @param cc data to log (byte). * @throws IOException IOException if an I/O error occurs. In particular, * an <code>IOException may be thrown if the * output stream has been closed. */ public void write(int cc) throws IOException { final byte c = (byte) cc; if ((c == '\n') || (c == '\r')) { if (!skip) { processBuffer(); } } else { buffer.write(cc); } skip = (c == '\r'); } /** * Converts the buffer to a string and sends it to <code>processLine */ protected void processBuffer() { handler.process(buffer.toString()); buffer.reset(); } /** * Writes all remaining * @throws IOException if an I/O error occurs. */ public void close() throws IOException { if (buffer.size() > 0) { processBuffer(); } super.close(); } } Other Ant examples (source code examples)Here is a short list of links related to this Ant P4OutputStream.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.