anchor.diff:    }
   
     @java.lang.Override
  -  protected boolean bulkCollectDataForSubscriptionUpdate( @javax.annotation.Nullable final org.realityforge.replicant.server.transport.ReplicantSession session, @javax.annotation.Nonnull final java.util.ArrayList<org.realityforge.replicant.server.ChannelAddress> descriptors, @javax.annotation.Nonnull final org.realityforge.replicant.server.ChangeSet changeSet, @javax.annotation.Nullable final Object originalFilter, @javax.annotation.Nullable final Object filter )
  +  protected boolean bulkCollectDataForSubscriptionUpdate( @javax.annotation.Nonnull final org.realityforge.replicant.server.transport.ReplicantSession session, @javax.annotation.Nonnull final java.util.ArrayList<org.realityforge.replicant.server.ChannelAddress> descriptors, @javax.annotation.Nonnull final org.realityforge.replicant.server.ChangeSet changeSet, @javax.annotation.Nullable final Object originalFilter, @javax.annotation.Nullable final Object filter )
     {
       if( descriptors.isEmpty() )
       {
  
positive.code:   }
  
    @java.lang.Override
    protected boolean bulkCollectDataForSubscribe( @javax.annotation.Nullable final org.realityforge.replicant.server.transport.ReplicantSession session, @javax.annotation.Nonnull final java.util.ArrayList<org.realityforge.replicant.server.ChannelAddress> descriptors, @javax.annotation.Nonnull final org.realityforge.replicant.server.ChangeSet changeSet, @javax.annotation.Nullable final Object filter, final boolean explicitSubscribe )
    {
      if( descriptors.isEmpty() )
      {
  
negative.code: <% end -%>
  
    @java.lang.Override
    @javax.annotation.Nullable
    protected java.lang.String collectDataForSubscribe(  @javax.annotation.Nonnull final org.realityforge.replicant.server.ChannelAddress address,@javax.annotation.Nonnull final org.realityforge.replicant.server.ChangeSet changeSet,@javax.annotation.Nullable final Object filter )
    {
      <%
  