parallel-collectors — version HEAD — recovered with pkg
graph TD
Abstractparallelcollector["Abstractparallelcollector\n(1 entities)"]
Abstractparallelcollector2["Abstractparallelcollector2\n(1 entities)"]
Accumulator["Accumulator\n(1 entities)"]
Characteristics["Characteristics\n(1 entities)"]
Combiner["Combiner\n(1 entities)"]
Finalizer["Finalizer\n(1 entities)"]
Finisher["Finisher\n(1 entities)"]
Supplier["Supplier\n(1 entities)"]
Asyncparallelcollector["Asyncparallelcollector\n(1 entities)"]
Asyncparallelcollector2["Asyncparallelcollector2\n(1 entities)"]
Finalizer2["Finalizer2\n(1 entities)"]
Asyncparallelstreamingcollector["Asyncparallelstreamingcollector\n(1 entities)"]
Asyncparallelstreamingcollector2["Asyncparallelstreamingcollector2\n(1 entities)"]
Characteristics2["Characteristics2\n(1 entities)"]
Finalizer3["Finalizer3\n(1 entities)"]
Joininterruptibly["Joininterruptibly\n(1 entities)"]
Joinwithin["Joinwithin\n(1 entities)"]
Orderedstream["Orderedstream\n(1 entities)"]
Batchingspliterator["Batchingspliterator\n(1 entities)"]
Batchingspliterator2["Batchingspliterator2\n(1 entities)"]
Assingletonliststream["Assingletonliststream\n(1 entities)"]
Batching["Batching\n(1 entities)"]
Characteristics3["Characteristics3\n(1 entities)"]
Estimatesize["Estimatesize\n(1 entities)"]
Partitioned["Partitioned\n(1 entities)"]
Tryadvance["Tryadvance\n(1 entities)"]
Trysplit["Trysplit\n(1 entities)"]
Collectingconfigurer["Collectingconfigurer\n(1 entities)"]
Collectingconfigurer2["Collectingconfigurer2\n(1 entities)"]
Addonce["Addonce\n(1 entities)"]
Batching2["Batching2\n(1 entities)"]
Executor["Executor\n(1 entities)"]
Executordecorator["Executordecorator\n(1 entities)"]
Getconfig["Getconfig\n(1 entities)"]
Parallelism["Parallelism\n(1 entities)"]
Taskdecorator["Taskdecorator\n(1 entities)"]
Validate["Validate\n(1 entities)"]
Completionorderspliterator["Completionorderspliterator\n(1 entities)"]
Completionorderspliterator2["Completionorderspliterator2\n(1 entities)"]
Characteristics4["Characteristics4\n(1 entities)"]
Estimatesize2["Estimatesize2\n(1 entities)"]
Nextcompleted["Nextcompleted\n(1 entities)"]
Tryadvance2["Tryadvance2\n(1 entities)"]
Trysplit2["Trysplit2\n(1 entities)"]
Completionstrategy["Completionstrategy\n(1 entities)"]
Configprocessor["Configprocessor\n(1 entities)"]
Process["Process\n(1 entities)"]
Tohumanreadablestring["Tohumanreadablestring\n(1 entities)"]
Deadline["Deadline\n(1 entities)"]
Deadline2["Deadline2\n(1 entities)"]
Remainingnanos["Remainingnanos\n(1 entities)"]
Dispatcher["Dispatcher\n(1 entities)"]
Dispatcher2["Dispatcher2\n(1 entities)"]
Abort["Abort\n(1 entities)"]
Registerterminationguard["Registerterminationguard\n(1 entities)"]
Retry["Retry\n(1 entities)"]
Start["Start\n(1 entities)"]
Stop["Stop\n(1 entities)"]
Submit["Submit\n(1 entities)"]
Wasshutdown["Wasshutdown\n(1 entities)"]
Wasstarted["Wasstarted\n(1 entities)"]
Factory["Factory\n(1 entities)"]
Factory2["Factory2\n(1 entities)"]
Collecting["Collecting\n(1 entities)"]
Collectingby["Collectingby\n(1 entities)"]
Select["Select\n(1 entities)"]
Streaming["Streaming\n(1 entities)"]
Streamingby["Streamingby\n(1 entities)"]
Futurecollectors["Futurecollectors\n(1 entities)"]
Tofuture["Tofuture\n(1 entities)"]
Interruptiblecompletablefuture["Interruptiblecompletablefuture\n(1 entities)"]
Cancel["Cancel\n(1 entities)"]
Completedby["Completedby\n(1 entities)"]
Parallelcollectors["Parallelcollectors\n(1 entities)"]
Parallelcollectors2["Parallelcollectors2\n(1 entities)"]
Parallel["Parallel\n(1 entities)"]
Parallelby["Parallelby\n(1 entities)"]
Paralleltostream["Paralleltostream\n(1 entities)"]
Paralleltostreamby["Paralleltostreamby\n(1 entities)"]
Tofuture2["Tofuture2\n(1 entities)"]
Preconditions["Preconditions\n(1 entities)"]
Preconditions2["Preconditions2\n(1 entities)"]
Requirevalidexecutor["Requirevalidexecutor\n(1 entities)"]
Requirevalidparallelism["Requirevalidparallelism\n(1 entities)"]
Requirevalidtimeout["Requirevalidtimeout\n(1 entities)"]
Streamingconfigurer["Streamingconfigurer\n(1 entities)"]
Streamingconfigurer2["Streamingconfigurer2\n(1 entities)"]
Addonce2["Addonce2\n(1 entities)"]
Batching3["Batching3\n(1 entities)"]
Executor2["Executor2\n(1 entities)"]
Executordecorator2["Executordecorator2\n(1 entities)"]
Getconfig2["Getconfig2\n(1 entities)"]
Ordered["Ordered\n(1 entities)"]
Parallelism2["Parallelism2\n(1 entities)"]
Taskdecorator2["Taskdecorator2\n(1 entities)"]
Timeout["Timeout\n(1 entities)"]
Validate2["Validate2\n(1 entities)"]
Abort --> Requirevalidexecutor
Asyncparallelcollector --> Batching
Asyncparallelcollector --> Partitioned
Asyncparallelcollector2 --> Batching
Asyncparallelcollector2 --> Partitioned
Asyncparallelstreamingcollector --> Batching
Asyncparallelstreamingcollector --> Partitioned
Asyncparallelstreamingcollector2 --> Batching
Asyncparallelstreamingcollector2 --> Partitioned
Characteristics2 --> Batching
Characteristics2 --> Partitioned
Dispatcher --> Requirevalidexecutor
Dispatcher2 --> Requirevalidexecutor
Finalizer2 --> Batching
Finalizer2 --> Partitioned
Finalizer3 --> Batching
Finalizer3 --> Partitioned
Joininterruptibly --> Batching
Joininterruptibly --> Partitioned
Joinwithin --> Batching
Joinwithin --> Partitioned
Orderedstream --> Batching
Orderedstream --> Partitioned
Registerterminationguard --> Requirevalidexecutor
Retry --> Requirevalidexecutor
Start --> Requirevalidexecutor
Stop --> Requirevalidexecutor
Submit --> Requirevalidexecutor
Wasshutdown --> Requirevalidexecutor
Wasstarted --> Requirevalidexecutor
| Component | Responsibility | # | Entities |
|---|---|---|---|
| Abstractparallelcollector | Entities in AbstractParallelCollector | 1 | com.pivovarit.collectors.AbstractParallelCollector |
| Abstractparallelcollector2 | Entities in AbstractParallelCollector.AbstractParallelCollector | 1 | com.pivovarit.collectors.AbstractParallelCollector.AbstractParallelCollector |
| Accumulator | Entities in AbstractParallelCollector.accumulator | 1 | com.pivovarit.collectors.AbstractParallelCollector.accumulator |
| Characteristics | Entities in AbstractParallelCollector.characteristics | 1 | com.pivovarit.collectors.AbstractParallelCollector.characteristics |
| Combiner | Entities in AbstractParallelCollector.combiner | 1 | com.pivovarit.collectors.AbstractParallelCollector.combiner |
| Finalizer | Entities in AbstractParallelCollector.finalizer | 1 | com.pivovarit.collectors.AbstractParallelCollector.finalizer |
| Finisher | Entities in AbstractParallelCollector.finisher | 1 | com.pivovarit.collectors.AbstractParallelCollector.finisher |
| Supplier | Entities in AbstractParallelCollector.supplier | 1 | com.pivovarit.collectors.AbstractParallelCollector.supplier |
| Asyncparallelcollector | Entities in AsyncParallelCollector | 1 | com.pivovarit.collectors.AsyncParallelCollector |
| Asyncparallelcollector2 | Entities in AsyncParallelCollector.AsyncParallelCollector | 1 | com.pivovarit.collectors.AsyncParallelCollector.AsyncParallelCollector |
| Finalizer2 | Entities in AsyncParallelCollector.finalizer | 1 | com.pivovarit.collectors.AsyncParallelCollector.finalizer |
| Asyncparallelstreamingcollector | Entities in AsyncParallelStreamingCollector | 1 | com.pivovarit.collectors.AsyncParallelStreamingCollector |
| Asyncparallelstreamingcollector2 | Entities in AsyncParallelStreamingCollector.AsyncParallelStreamingCollector | 1 | com.pivovarit.collectors.AsyncParallelStreamingCollector.AsyncParallelStreamingCollector |
| Characteristics2 | Entities in AsyncParallelStreamingCollector.characteristics | 1 | com.pivovarit.collectors.AsyncParallelStreamingCollector.characteristics |
| Finalizer3 | Entities in AsyncParallelStreamingCollector.finalizer | 1 | com.pivovarit.collectors.AsyncParallelStreamingCollector.finalizer |
| Joininterruptibly | Entities in AsyncParallelStreamingCollector.joinInterruptibly | 1 | com.pivovarit.collectors.AsyncParallelStreamingCollector.joinInterruptibly |
| Joinwithin | Entities in AsyncParallelStreamingCollector.joinWithin | 1 | com.pivovarit.collectors.AsyncParallelStreamingCollector.joinWithin |
| Orderedstream | Entities in AsyncParallelStreamingCollector.orderedStream | 1 | com.pivovarit.collectors.AsyncParallelStreamingCollector.orderedStream |
| Batchingspliterator | Entities in BatchingSpliterator | 1 | com.pivovarit.collectors.BatchingSpliterator |
| Batchingspliterator2 | Entities in BatchingSpliterator.BatchingSpliterator | 1 | com.pivovarit.collectors.BatchingSpliterator.BatchingSpliterator |
| Assingletonliststream | Entities in BatchingSpliterator.asSingletonListStream | 1 | com.pivovarit.collectors.BatchingSpliterator.asSingletonListStream |
| Batching | Entities in BatchingSpliterator.batching | 1 | com.pivovarit.collectors.BatchingSpliterator.batching |
| Characteristics3 | Entities in BatchingSpliterator.characteristics | 1 | com.pivovarit.collectors.BatchingSpliterator.characteristics |
| Estimatesize | Entities in BatchingSpliterator.estimateSize | 1 | com.pivovarit.collectors.BatchingSpliterator.estimateSize |
| Partitioned | Entities in BatchingSpliterator.partitioned | 1 | com.pivovarit.collectors.BatchingSpliterator.partitioned |
| Tryadvance | Entities in BatchingSpliterator.tryAdvance | 1 | com.pivovarit.collectors.BatchingSpliterator.tryAdvance |
| Trysplit | Entities in BatchingSpliterator.trySplit | 1 | com.pivovarit.collectors.BatchingSpliterator.trySplit |
| Collectingconfigurer | Entities in CollectingConfigurer | 1 | com.pivovarit.collectors.CollectingConfigurer |
| Collectingconfigurer2 | Entities in CollectingConfigurer.CollectingConfigurer | 1 | com.pivovarit.collectors.CollectingConfigurer.CollectingConfigurer |
| Addonce | Entities in CollectingConfigurer.addOnce | 1 | com.pivovarit.collectors.CollectingConfigurer.addOnce |
| Batching2 | Entities in CollectingConfigurer.batching | 1 | com.pivovarit.collectors.CollectingConfigurer.batching |
| Executor | Entities in CollectingConfigurer.executor | 1 | com.pivovarit.collectors.CollectingConfigurer.executor |
| Executordecorator | Entities in CollectingConfigurer.executorDecorator | 1 | com.pivovarit.collectors.CollectingConfigurer.executorDecorator |
| Getconfig | Entities in CollectingConfigurer.getConfig | 1 | com.pivovarit.collectors.CollectingConfigurer.getConfig |
| Parallelism | Entities in CollectingConfigurer.parallelism | 1 | com.pivovarit.collectors.CollectingConfigurer.parallelism |
| Taskdecorator | Entities in CollectingConfigurer.taskDecorator | 1 | com.pivovarit.collectors.CollectingConfigurer.taskDecorator |
| Validate | Entities in CollectingConfigurer.validate | 1 | com.pivovarit.collectors.CollectingConfigurer.validate |
| Completionorderspliterator | Entities in CompletionOrderSpliterator | 1 | com.pivovarit.collectors.CompletionOrderSpliterator |
| Completionorderspliterator2 | Entities in CompletionOrderSpliterator.CompletionOrderSpliterator | 1 | com.pivovarit.collectors.CompletionOrderSpliterator.CompletionOrderSpliterator |
| Characteristics4 | Entities in CompletionOrderSpliterator.characteristics | 1 | com.pivovarit.collectors.CompletionOrderSpliterator.characteristics |
| Estimatesize2 | Entities in CompletionOrderSpliterator.estimateSize | 1 | com.pivovarit.collectors.CompletionOrderSpliterator.estimateSize |
| Nextcompleted | Entities in CompletionOrderSpliterator.nextCompleted | 1 | com.pivovarit.collectors.CompletionOrderSpliterator.nextCompleted |
| Tryadvance2 | Entities in CompletionOrderSpliterator.tryAdvance | 1 | com.pivovarit.collectors.CompletionOrderSpliterator.tryAdvance |
| Trysplit2 | Entities in CompletionOrderSpliterator.trySplit | 1 | com.pivovarit.collectors.CompletionOrderSpliterator.trySplit |
| Completionstrategy | Entities in CompletionStrategy | 1 | com.pivovarit.collectors.CompletionStrategy |
| Configprocessor | Entities in ConfigProcessor | 1 | com.pivovarit.collectors.ConfigProcessor |
| Process | Entities in ConfigProcessor.process | 1 | com.pivovarit.collectors.ConfigProcessor.process |
| Tohumanreadablestring | Entities in ConfigProcessor.toHumanReadableString | 1 | com.pivovarit.collectors.ConfigProcessor.toHumanReadableString |
| Deadline | Entities in Deadline | 1 | com.pivovarit.collectors.Deadline |
| Deadline2 | Entities in Deadline.Deadline | 1 | com.pivovarit.collectors.Deadline.Deadline |
| Remainingnanos | Entities in Deadline.remainingNanos | 1 | com.pivovarit.collectors.Deadline.remainingNanos |
| Dispatcher | Entities in Dispatcher | 1 | com.pivovarit.collectors.Dispatcher |
| Dispatcher2 | Entities in Dispatcher.Dispatcher | 1 | com.pivovarit.collectors.Dispatcher.Dispatcher |
| Abort | Entities in Dispatcher.abort | 1 | com.pivovarit.collectors.Dispatcher.abort |
| Registerterminationguard | Entities in Dispatcher.registerTerminationGuard | 1 | com.pivovarit.collectors.Dispatcher.registerTerminationGuard |
| Retry | Entities in Dispatcher.retry | 1 | com.pivovarit.collectors.Dispatcher.retry |
| Start | Entities in Dispatcher.start | 1 | com.pivovarit.collectors.Dispatcher.start |
| Stop | Entities in Dispatcher.stop | 1 | com.pivovarit.collectors.Dispatcher.stop |
| Submit | Entities in Dispatcher.submit | 1 | com.pivovarit.collectors.Dispatcher.submit |
| Wasshutdown | Entities in Dispatcher.wasShutdown | 1 | com.pivovarit.collectors.Dispatcher.wasShutdown |
| Wasstarted | Entities in Dispatcher.wasStarted | 1 | com.pivovarit.collectors.Dispatcher.wasStarted |
| Factory | Entities in Factory | 1 | com.pivovarit.collectors.Factory |
| Factory2 | Entities in Factory.Factory | 1 | com.pivovarit.collectors.Factory.Factory |
| Collecting | Entities in Factory.collecting | 1 | com.pivovarit.collectors.Factory.collecting |
| Collectingby | Entities in Factory.collectingBy | 1 | com.pivovarit.collectors.Factory.collectingBy |
| Select | Entities in Factory.select | 1 | com.pivovarit.collectors.Factory.select |
| Streaming | Entities in Factory.streaming | 1 | com.pivovarit.collectors.Factory.streaming |
| Streamingby | Entities in Factory.streamingBy | 1 | com.pivovarit.collectors.Factory.streamingBy |
| Futurecollectors | Entities in FutureCollectors | 1 | com.pivovarit.collectors.FutureCollectors |
| Tofuture | Entities in FutureCollectors.toFuture | 1 | com.pivovarit.collectors.FutureCollectors.toFuture |
| Interruptiblecompletablefuture | Entities in InterruptibleCompletableFuture | 1 | com.pivovarit.collectors.InterruptibleCompletableFuture |
| Cancel | Entities in InterruptibleCompletableFuture.cancel | 1 | com.pivovarit.collectors.InterruptibleCompletableFuture.cancel |
| Completedby | Entities in InterruptibleCompletableFuture.completedBy | 1 | com.pivovarit.collectors.InterruptibleCompletableFuture.completedBy |
| Parallelcollectors | Entities in ParallelCollectors | 1 | com.pivovarit.collectors.ParallelCollectors |
| Parallelcollectors2 | Entities in ParallelCollectors.ParallelCollectors | 1 | com.pivovarit.collectors.ParallelCollectors.ParallelCollectors |
| Parallel | Entities in ParallelCollectors.parallel | 1 | com.pivovarit.collectors.ParallelCollectors.parallel |
| Parallelby | Entities in ParallelCollectors.parallelBy | 1 | com.pivovarit.collectors.ParallelCollectors.parallelBy |
| Paralleltostream | Entities in ParallelCollectors.parallelToStream | 1 | com.pivovarit.collectors.ParallelCollectors.parallelToStream |
| Paralleltostreamby | Entities in ParallelCollectors.parallelToStreamBy | 1 | com.pivovarit.collectors.ParallelCollectors.parallelToStreamBy |
| Tofuture2 | Entities in ParallelCollectors.toFuture | 1 | com.pivovarit.collectors.ParallelCollectors.toFuture |
| Preconditions | Entities in Preconditions | 1 | com.pivovarit.collectors.Preconditions |
| Preconditions2 | Entities in Preconditions.Preconditions | 1 | com.pivovarit.collectors.Preconditions.Preconditions |
| Requirevalidexecutor | Entities in Preconditions.requireValidExecutor | 1 | com.pivovarit.collectors.Preconditions.requireValidExecutor |
| Requirevalidparallelism | Entities in Preconditions.requireValidParallelism | 1 | com.pivovarit.collectors.Preconditions.requireValidParallelism |
| Requirevalidtimeout | Entities in Preconditions.requireValidTimeout | 1 | com.pivovarit.collectors.Preconditions.requireValidTimeout |
| Streamingconfigurer | Entities in StreamingConfigurer | 1 | com.pivovarit.collectors.StreamingConfigurer |
| Streamingconfigurer2 | Entities in StreamingConfigurer.StreamingConfigurer | 1 | com.pivovarit.collectors.StreamingConfigurer.StreamingConfigurer |
| Addonce2 | Entities in StreamingConfigurer.addOnce | 1 | com.pivovarit.collectors.StreamingConfigurer.addOnce |
| Batching3 | Entities in StreamingConfigurer.batching | 1 | com.pivovarit.collectors.StreamingConfigurer.batching |
| Executor2 | Entities in StreamingConfigurer.executor | 1 | com.pivovarit.collectors.StreamingConfigurer.executor |
| Executordecorator2 | Entities in StreamingConfigurer.executorDecorator | 1 | com.pivovarit.collectors.StreamingConfigurer.executorDecorator |
| Getconfig2 | Entities in StreamingConfigurer.getConfig | 1 | com.pivovarit.collectors.StreamingConfigurer.getConfig |
| Ordered | Entities in StreamingConfigurer.ordered | 1 | com.pivovarit.collectors.StreamingConfigurer.ordered |
| Parallelism2 | Entities in StreamingConfigurer.parallelism | 1 | com.pivovarit.collectors.StreamingConfigurer.parallelism |
| Taskdecorator2 | Entities in StreamingConfigurer.taskDecorator | 1 | com.pivovarit.collectors.StreamingConfigurer.taskDecorator |
| Timeout | Entities in StreamingConfigurer.timeout | 1 | com.pivovarit.collectors.StreamingConfigurer.timeout |
| Validate2 | Entities in StreamingConfigurer.validate | 1 | com.pivovarit.collectors.StreamingConfigurer.validate |
No architectural smells detected. The architecture appears well-structured.
| Package | Entities |
|---|---|
com.pivovarit.collectors |
124 |