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 NullStream extends BaseStream implements IStreamDest {
    protected int files = 0;
    protected long bytes = 0;
    @Override
    public void init(StackEntry stackXElement elboolean autorelative) {
    }
    
	// make sure we don't return without first releasing the file reference content
    @Override
    public HandleReturn handle(TaskRun cbStreamMessage msg) {
    	if (msg == .) {
    		cb.info("Null got " + this. + " bytes and " + this. + " files/folders.");
    		
    		cb.complete();
           	return .;
    	}
       	
    	if (msg.isEof())
    		this.++;
    	
    	ByteBuf pay = msg.getPayload();
    	
    	if (pay != null) {
    		this. += pay.readableBytes();
    		pay.release();
    	}
    	
       	return .;
    }
    
    @Override
    public void request(TaskRun cb) {
    	this..request(cb);
    }
	public void execute(TaskRun cb) {
		this..request(cb);
	}
New to GrepCode? Check out our FAQ X