@Test public void onInSync() { final Connector connector = createConnector(); final TestSpyEventHandler handler = registerTestSpyEventHandler(); connector.onInSync(); handler.assertEventCount( 1 ); handler.assertNextEvent( InSyncEvent.class, e -> assertEquals( e.getSchemaId(), connector.getSchema().getId() ) ); }
void onInSync() { if ( Replicant.areSpiesEnabled() && getReplicantContext().getSpy().willPropagateSpyEvents() ) { getReplicantContext().getSpy().reportSpyEvent( new InSyncEvent( getSchema().getId() ) ); } }
Connector extends ReplicantService { void onInSync() { if ( Replicant.areSpiesEnabled() && getReplicantContext().getSpy().willPropagateSpyEvents() ) { getReplicantContext().getSpy().reportSpyEvent( new InSyncEvent( getSchema().getId() ) ); } } }
Connector extends ReplicantService { void onInSync() { if ( Replicant.areSpiesEnabled() && getReplicantContext().getSpy().willPropagateSpyEvents() ) { getReplicantContext().getSpy().reportSpyEvent( new InSyncEvent( getSchema().getId() ) ); } } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); }
Connector extends ReplicantService { void onInSync() { if ( Replicant.areSpiesEnabled() && getReplicantContext().getSpy().willPropagateSpyEvents() ) { getReplicantContext().getSpy().reportSpyEvent( new InSyncEvent( getSchema().getId() ) ); } } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); @Override String toString(); }
Connector extends ReplicantService { void onInSync() { if ( Replicant.areSpiesEnabled() && getReplicantContext().getSpy().willPropagateSpyEvents() ) { getReplicantContext().getSpy().reportSpyEvent( new InSyncEvent( getSchema().getId() ) ); } } Connector( @Nullable final ReplicantContext context,
             @Nonnull final SystemSchema schema,
             @Nonnull final Transport transport ); @Override String toString();  }