Lines Matching refs:next
106 * If this field is non-null, the next instruction to execute is
110 private Tube next;
241 next = tubeline;
249 next = tubeline;
260 * If a fiber was suspended without specifying the next {@link Tube},
262 * by calling the {@link Tube#processResponse(Packet)} method on the next/first
267 * If a fiber was suspended with specifying the next {@link Tube},
269 * by calling the next tube's {@link Tube#processRequest(Packet)} method with the
299 * on the next/first {@link Tube} in the {@link Fiber}'s processing stack with
342 * {@link Tube#processResponse(Packet)}, before the next tube begins processing.
370 * {@link Tube#processResponse(Packet)}, before the next tube begins processing.
419 next = doRun(next);
436 * return doReturnWith(Fiber.current().runSync(next,request));
521 * Index in {@link Fiber#interceptors} to invoke next.
528 Tube invoke(Tube next) {
530 return execute(next);
533 public Tube execute(Tube next) {
535 return __doRun(next);
538 return interceptor.execute(Fiber.this,next,this);
546 * @param next
547 * The next tube whose {@link Tube#processRequest(Packet)} is to be invoked. If null,
551 * If non-null, the next time execution resumes, it should resume from calling
556 private Tube doRun(Tube next) {
565 return _doRun(next);
570 return _doRun(next);
574 private Tube _doRun(Tube next) {
585 next = __doRun(next);
587 next = interceptorHandler.invoke(next);
590 return next;
601 private Tube __doRun(Tube next) {
623 if(next!=null) {
625 LOGGER.finer(getName()+' '+next+".processRequest("+packet+')');
626 na = next.processRequest(packet);
627 last = next;
653 // fall through next
655 next = na.next;
659 next = null;
663 next = na.next;
681 return next;
770 * the next {@link Tube}. For example, a tube may want to install