jar

org.streamingpool : streamingpool-core

Maven & Gradle

May 11, 2021
3 usages
5 stars

org.streamingpool:streamingpool-core · This project is an high level abstraction over Reactive Streams libraries that is currently used inside CERN.

Table Of Contents

Latest Version

Download org.streamingpool : streamingpool-core JAR file - Latest Versions:

All Versions

Download org.streamingpool : streamingpool-core JAR file - All Versions:

Version Vulnerabilities Size Updated
1.5.x
1.4.x
1.2.x
1.1.x
1.0.x
0.0.x

View Java Class Source Code in JAR file

  1. Download JD-GUI to open JAR file and explore Java source code file (.class .java)
  2. Click menu "File → Open File..." or just drag-and-drop the JAR file in the JD-GUI window streamingpool-core-1.5.0.jar file.
    Once you open a JAR file, all the java classes in the JAR file will be displayed.

org.streamingpool.core.service.util

├─ org.streamingpool.core.service.util.DoAfterFirstSubscribe.class - [JAR]

├─ org.streamingpool.core.service.util.ReactiveStreams.class - [JAR]

├─ org.streamingpool.core.service.util.StreamCreators.class - [JAR]

org.streamingpool.core.service.streamid.factory

├─ org.streamingpool.core.service.streamid.factory.ComposedStreams.class - [JAR]

org.streamingpool.core.rx.process

├─ org.streamingpool.core.rx.process.Choosable.class - [JAR]

├─ org.streamingpool.core.rx.process.ClearableBufferProcessor.class - [JAR]

├─ org.streamingpool.core.rx.process.ConcurrentCircularBuffer.class - [JAR]

├─ org.streamingpool.core.rx.process.ObservableChoosable.class - [JAR]

├─ org.streamingpool.core.rx.process.RunState.class - [JAR]

├─ org.streamingpool.core.rx.process.RunStateService.class - [JAR]

├─ org.streamingpool.core.rx.process.RunStateServiceImpl.class - [JAR]

├─ org.streamingpool.core.rx.process.Trigger.class - [JAR]

├─ org.streamingpool.core.rx.process.TriggerImpl.class - [JAR]

org.streamingpool.core.service.streamfactory

├─ org.streamingpool.core.service.streamfactory.CombineWithLatestStreamFactory.class - [JAR]

├─ org.streamingpool.core.service.streamfactory.CompositionStreamFactory.class - [JAR]

├─ org.streamingpool.core.service.streamfactory.CreatorStreamFactory.class - [JAR]

├─ org.streamingpool.core.service.streamfactory.DelayedStreamFactory.class - [JAR]

├─ org.streamingpool.core.service.streamfactory.DerivedStreamFactory.class - [JAR]

├─ org.streamingpool.core.service.streamfactory.FanOutStreamFactory.class - [JAR]

├─ org.streamingpool.core.service.streamfactory.FilteredStreamFactory.class - [JAR]

├─ org.streamingpool.core.service.streamfactory.FlattenedStreamFactory.class - [JAR]

├─ org.streamingpool.core.service.streamfactory.IntervalStreamFactory.class - [JAR]

├─ org.streamingpool.core.service.streamfactory.MergedErrorStreamFactory.class - [JAR]

├─ org.streamingpool.core.service.streamfactory.OverlapBufferStreamFactory.class - [JAR]

├─ org.streamingpool.core.service.streamfactory.ZippedStreamFactory.class - [JAR]

org.streamingpool.core.testing.util

├─ org.streamingpool.core.testing.util.UncheckedWaits.class - [JAR]

org.streamingpool.core.service.impl

├─ org.streamingpool.core.service.impl.IdentifiedStreamCreator.class - [JAR]

├─ org.streamingpool.core.service.impl.ImmutableIdentifiedStreamCreator.class - [JAR]

├─ org.streamingpool.core.service.impl.InstrumentationServiceImpl.class - [JAR]

├─ org.streamingpool.core.service.impl.LocalPool.class - [JAR]

├─ org.streamingpool.core.service.impl.PoolContent.class - [JAR]

├─ org.streamingpool.core.service.impl.TrackKeepingDiscoveryService.class - [JAR]

org.streamingpool.core.service.streamid

├─ org.streamingpool.core.service.streamid.BufferSpecification.class - [JAR]

├─ org.streamingpool.core.service.streamid.ClassBasedId.class - [JAR]

├─ org.streamingpool.core.service.streamid.CombineWithLatestStreamId.class - [JAR]

├─ org.streamingpool.core.service.streamid.CompositionStreamId.class - [JAR]

├─ org.streamingpool.core.service.streamid.DelayedStreamId.class - [JAR]

├─ org.streamingpool.core.service.streamid.DerivedStreamId.class - [JAR]

├─ org.streamingpool.core.service.streamid.FanOutStreamId.class - [JAR]

├─ org.streamingpool.core.service.streamid.FilteredStreamId.class - [JAR]

├─ org.streamingpool.core.service.streamid.FlattenedStreamId.class - [JAR]

├─ org.streamingpool.core.service.streamid.IntervalStreamId.class - [JAR]

├─ org.streamingpool.core.service.streamid.MergedErrorStreamId.class - [JAR]

├─ org.streamingpool.core.service.streamid.OverlapBufferStreamId.class - [JAR]

├─ org.streamingpool.core.service.streamid.StreamingPoolHook.class - [JAR]

├─ org.streamingpool.core.service.streamid.ZippedStreamId.class - [JAR]

org.streamingpool.core.service.streamid.factory.function

├─ org.streamingpool.core.service.streamid.factory.function.DelayCompositionFunction.class - [JAR]

├─ org.streamingpool.core.service.streamid.factory.function.FilterCompositionFunction.class - [JAR]

├─ org.streamingpool.core.service.streamid.factory.function.FlatMapCompositionFunction.class - [JAR]

├─ org.streamingpool.core.service.streamid.factory.function.MapCompositionFunction.class - [JAR]

├─ org.streamingpool.core.service.streamid.factory.function.ZipCompositionFunction.class - [JAR]

org.streamingpool.core.service.rx

├─ org.streamingpool.core.service.rx.RxStreams.class - [JAR]

org.streamingpool.core.service

├─ org.streamingpool.core.service.CreatorProvidingService.class - [JAR]

├─ org.streamingpool.core.service.CycleInStreamDiscoveryDetectedException.class - [JAR]

├─ org.streamingpool.core.service.DiscoveryService.class - [JAR]

├─ org.streamingpool.core.service.InstrumentationService.class - [JAR]

├─ org.streamingpool.core.service.ProvidingService.class - [JAR]

├─ org.streamingpool.core.service.StreamCreator.class - [JAR]

├─ org.streamingpool.core.service.StreamFactory.class - [JAR]

├─ org.streamingpool.core.service.StreamFactoryRegistry.class - [JAR]

├─ org.streamingpool.core.service.StreamId.class - [JAR]

├─ org.streamingpool.core.service.TypedStreamFactory.class - [JAR]

org.streamingpool.core.domain.backpressure

├─ org.streamingpool.core.domain.backpressure.BackpressureAware.class - [JAR]

├─ org.streamingpool.core.domain.backpressure.BackpressureBufferStrategy.class - [JAR]

├─ org.streamingpool.core.domain.backpressure.BackpressureDropStrategy.class - [JAR]

├─ org.streamingpool.core.domain.backpressure.BackpressureLatestStrategy.class - [JAR]

├─ org.streamingpool.core.domain.backpressure.BackpressureNoneStrategy.class - [JAR]

├─ org.streamingpool.core.domain.backpressure.BackpressureStrategies.class - [JAR]

├─ org.streamingpool.core.domain.backpressure.BackpressureStrategy.class - [JAR]

org.streamingpool.core.service.diagnostic

├─ org.streamingpool.core.service.diagnostic.ErrorStreamId.class - [JAR]

org.streamingpool.core.util

├─ org.streamingpool.core.util.MoreCollections.class - [JAR]

├─ org.streamingpool.core.util.ObjectVerifications.class - [JAR]

org.streamingpool.core.support

├─ org.streamingpool.core.support.AbstractStreamSupport.class - [JAR]

├─ org.streamingpool.core.support.RxStreamSupport.class - [JAR]

├─ org.streamingpool.core.support.StreamCollectingSupport.class - [JAR]

├─ org.streamingpool.core.support.StreamSupport.class - [JAR]

org.streamingpool.core.conf

├─ org.streamingpool.core.conf.DefaultPoolConfiguration.class - [JAR]

├─ org.streamingpool.core.conf.DefaultStreamFactories.class - [JAR]

├─ org.streamingpool.core.conf.EmbeddedPoolConfiguration.class - [JAR]

├─ org.streamingpool.core.conf.PoolConfiguration.class - [JAR]

├─ org.streamingpool.core.conf.StreamCreatorFactoryConfiguration.class - [JAR]

├─ org.streamingpool.core.conf.TestPoolConfiguration.class - [JAR]

org.streamingpool.core.testing

├─ org.streamingpool.core.testing.AbstractStreamTest.class - [JAR]

├─ org.streamingpool.core.testing.NamedStreamId.class - [JAR]

├─ org.streamingpool.core.testing.StreamFactoryMock.class - [JAR]

org.streamingpool.core.domain

├─ org.streamingpool.core.domain.ErrorDeflector.class - [JAR]

├─ org.streamingpool.core.domain.ErrorStreamException.class - [JAR]

├─ org.streamingpool.core.domain.ErrorStreamPair.class - [JAR]

├─ org.streamingpool.core.domain.StreamDependencyTree.class - [JAR]

├─ org.streamingpool.core.domain.SynchronizedStreamDependencyTree.class - [JAR]

├─ org.streamingpool.core.domain.Timestamped.class - [JAR]

Advertisement

Dependencies from Group

May 11, 2021
3 usages
5 stars
Jun 14, 2021
1 usages
0 stars
Jun 14, 2021
1 usages
0 stars
Jun 14, 2021
1 usages
0 stars

Discover Dependencies

Jul 04, 2023
30 usages
May 24, 2022
34 usages
51 stars
Nov 04, 2015
30 usages
1.8k stars
Jun 19, 2023
56 usages
Nov 18, 2019
24 usages
3 stars
Oct 24, 2008
2 usages
Oct 08, 2022
9 usages
1k stars
Dec 04, 2015
3 usages
467 stars
Jun 03, 2019
2 usages
491 stars