Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 /* ************************************************************************
 #
 #  DivConq
 #
 #  http://divconq.com/
 #
 #  Copyright:
 #    Copyright 2014 eTimeline, LLC. All rights reserved.
 #
#  License:
#    See the license.txt file in the project's top-level directory for details.
#  Authors:
#    * Andy White
************************************************************************ */
package divconq.io.stream;
public class JoinStream extends BaseStream implements IStreamSource {
    public JoinStream() {
    }
	public void init(StackEntry stackXElement el) {
	}
    
	// make sure we don't return without first releasing the file reference content
    @Override
    public HandleReturn handle(TaskRun cbStreamMessage msg) {
    	if (msg == .
    		return this..handle(cbmsg);
    	ByteBuf in = msg.getPayload();
		return this..handle(cbthis.nextMessage(inmsg));
    }
    
    public StreamMessage nextMessage(ByteBuf outStreamMessage curr) {
		// create the output message
		StreamMessage blk = new StreamMessage();
        blk.setPayload(out);
        blk.setModified(System.currentTimeMillis());		
        
        // keep the path, just vary the name to the template
        blk.setPath(curr.getPath().resolvePeer("/file.bin"));		// TODO support other names, currently assumes we are writing to a file dest instead of folder dest so name ignored
       	blk.setFileSize(0);						// don't know size ahead of time
        
        return blk;
    }
    
    @Override
    public void request(TaskRun cb) {
    	this..request(cb);
    }
New to GrepCode? Check out our FAQ X