PublishAnnotatedOperation extends
    NetworkPublishOperation<D> { public Class<D> getSocketType() { return dataType; } protected  PublishAnnotatedOperation(InputSocket.Factory isf,
                                      Class<D> dataType,
                                      Class<P> publishType,
                                      Function<D, P> converter,
                                      MapNetworkPublisherFactory publisherFactory); Class<D> getSocketType(); @Override void cleanUp();  }
@Test public void testPublishProperlyResolvesSocketType() { TestPublishAnnotatedOperation<SimpleReport> testPublishAnnotatedOperation = new TestPublishAnnotatedOperation<>(SimpleReport.class); assertEquals("Socket types were not the same", testPublishAnnotatedOperation.getSocketType(), SimpleReport.class); }