Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package divconq.io.stream;
 
 
 public class CtpStreamSource extends BaseStream implements IStreamSource {
 	protected Channel chan = null;
	protected StreamMessage next = null;
	public void setNext(StreamMessage v) {
		this. = v;
	}
	public CtpStreamSource(Channel chanStreamMessage first) {
		this. = chan;
		this.setNext(first);
	}
	public void init(StackEntry stackXElement el) {
	}
	public void close() {
		super.close();
		this. = null;
		this. = null;
	}
	public HandleReturn handle(TaskRun cbStreamMessage msg) {
		if (this..handle(cbmsg) == .
			this..read();
		return null;
	}
	public void request(TaskRun cb) {
		if (this. != null) {
			StreamMessage f = this.;
			this. = null;
			if (this..handle(cbf) == .
				this..read();
		}
		else 
			this..read();
	}
New to GrepCode? Check out our FAQ X