anchor.diff:        }
       }
   
  -    accumulator.complete();
  +    return accumulator.complete( sessionID, jobID );
     }
   
     @javax.annotation.Nonnull
  
positive.code:   @javax.inject.Inject
    private <%= repository.imit.qualified_graph_encoder_name %> _encoder;
  
    @javax.annotation.Nonnull
    protected final <%= repository.imit.qualified_graph_encoder_name %> getEncoder()
    {
  
negative.code: <% else -%>
        collect<%= graph.key %>( messages );
  <% end -%>
        final String jobID = (String) _registry.getResource( org.realityforge.replicant.shared.transport.ReplicantContext.REQUEST_ID_KEY );
        session.getQueue().addPacket( jobID, messages );
      }
    }
  
  