@Test public void create() { BatchPayloadPublisherFactory factory = new AsyncBatchPayloadPublisherFactory(); BatchPayloadPublisher publisher = factory.create(mock(PayloadPublisher.class)); assertThat(publisher).isNotNull(); }
@Override public BatchPayloadPublisher create(PayloadPublisher publisher) { ExecutorFactory executorFactory = new ExecutorFactory(); CancellableCountDownLatchFactory countDownLatchFactory = new CancellableCountDownLatchFactory(); PayloadEncoder encoder = PayloadEncoder.create(); return new AsyncBatchPayloadPublisher(executorFactory, countDownLatchFactory, publisher, encoder); }
AsyncBatchPayloadPublisherFactory implements BatchPayloadPublisherFactory { @Override public BatchPayloadPublisher create(PayloadPublisher publisher) { ExecutorFactory executorFactory = new ExecutorFactory(); CancellableCountDownLatchFactory countDownLatchFactory = new CancellableCountDownLatchFactory(); PayloadEncoder encoder = PayloadEncoder.create(); return new AsyncBatchPayloadPublisher(executorFactory, countDownLatchFactory, publisher, encoder); } }
AsyncBatchPayloadPublisherFactory implements BatchPayloadPublisherFactory { @Override public BatchPayloadPublisher create(PayloadPublisher publisher) { ExecutorFactory executorFactory = new ExecutorFactory(); CancellableCountDownLatchFactory countDownLatchFactory = new CancellableCountDownLatchFactory(); PayloadEncoder encoder = PayloadEncoder.create(); return new AsyncBatchPayloadPublisher(executorFactory, countDownLatchFactory, publisher, encoder); }  }
AsyncBatchPayloadPublisherFactory implements BatchPayloadPublisherFactory { @Override public BatchPayloadPublisher create(PayloadPublisher publisher) { ExecutorFactory executorFactory = new ExecutorFactory(); CancellableCountDownLatchFactory countDownLatchFactory = new CancellableCountDownLatchFactory(); PayloadEncoder encoder = PayloadEncoder.create(); return new AsyncBatchPayloadPublisher(executorFactory, countDownLatchFactory, publisher, encoder); }  @Override BatchPayloadPublisher create(PayloadPublisher publisher); }
AsyncBatchPayloadPublisherFactory implements BatchPayloadPublisherFactory { @Override public BatchPayloadPublisher create(PayloadPublisher publisher) { ExecutorFactory executorFactory = new ExecutorFactory(); CancellableCountDownLatchFactory countDownLatchFactory = new CancellableCountDownLatchFactory(); PayloadEncoder encoder = PayloadEncoder.create(); return new AsyncBatchPayloadPublisher(executorFactory, countDownLatchFactory, publisher, encoder); }  @Override BatchPayloadPublisher create(PayloadPublisher publisher);  }