akka-stream-contrib_2.11-0.10.jar

<dependency>
	<groupId>com.typesafe.akka</groupId>
	<artifactId>akka-stream-contrib_2.11</artifactId>
	<version>0.10</version>
</dependency>

com.typesafe.akka:akka-stream-contrib_2.11:0.10

<?xml version='1.0' encoding='UTF-8'?>

<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0">

    <modelVersion>4.0.0</modelVersion>

    <groupId>com.typesafe.akka</groupId>

    <artifactId>akka-stream-contrib_2.11</artifactId>

    <packaging>jar</packaging>

    <description>akka-stream-contrib</description>

    <url>https://github.com/akka/akka-stream-contrib</url>

    <version>0.10</version>

    <licenses>

        <license>

            <name>Apache License, Version 2.0</name>

            <url>http://www.apache.org/licenses/LICENSE-2.0</url>

            <distribution>repo</distribution>

        </license>

    </licenses>

    <name>akka-stream-contrib</name>

    <organization>

        <name>Lightbend Inc.</name>

        <url>http://www.lightbend.com</url>

    </organization>

    <scm>

        <url>https://github.com/akka/akka-stream-contrib</url>

        <connection>git@github.com:akka/akka-stream-contrib.git</connection>

    </scm>

    <developers>

        <developer>

            <id>contributors</id>

            <name>Contributors</name>

            <email>https://gitter.im/akka/dev</email>

            <url>https://github.com/akka/akka-stream-contrib/graphs/contributors</url>

        </developer>

    </developers>

    <dependencies>

        <dependency>

            <groupId>org.scala-lang</groupId>

            <artifactId>scala-library</artifactId>

            <version>2.11.12</version>

        </dependency>

        <dependency>

            <groupId>com.typesafe.akka</groupId>

            <artifactId>akka-stream_2.11</artifactId>

            <version>2.5.23</version>

        </dependency>

        <dependency>

            <groupId>com.typesafe.akka</groupId>

            <artifactId>akka-stream-testkit_2.11</artifactId>

            <version>2.5.23</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>junit</groupId>

            <artifactId>junit</artifactId>

            <version>4.12</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>com.novocode</groupId>

            <artifactId>junit-interface</artifactId>

            <version>0.11</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>com.google.jimfs</groupId>

            <artifactId>jimfs</artifactId>

            <version>1.1</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>org.scalatest</groupId>

            <artifactId>scalatest_2.11</artifactId>

            <version>3.0.8</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>com.miguno.akka</groupId>

            <artifactId>akka-mock-scheduler_2.11</artifactId>

            <version>0.5.5</version>

            <scope>test</scope>

        </dependency>

    </dependencies>

</project>

META-INF/MANIFEST.MF
akka.stream.contrib.DelayFlow$.class
akka.stream.contrib.Retry$RetryConcatCoordinator$$anon$6$$anon$9$$anonfun$onPush$4.class
akka.stream.contrib.Retry$.class
akka.stream.contrib.TimedIntervalBetweenOps.class
akka.stream.contrib.FeedbackLoop$$anonfun$apply$1$$anonfun$apply$2.class
akka.stream.contrib.Retry$RetryConcatCoordinator$$anon$6$$anon$9.class
akka.stream.contrib.ZipInputStreamSource$$anon$1$$anonfun$read$1$1$$anonfun$apply$1.class
akka.stream.contrib.SourceGen$.class
akka.stream.contrib.ZipInputStreamSource$.class
akka.stream.contrib.Valve.class
akka.stream.contrib.LastElement$$anon$1.class
akka.stream.contrib.FileTailSource.class
akka.stream.contrib.PagedSource.class
akka.stream.contrib.Retry$RetryCoordinator$$anon$1$$anon$3.class
akka.stream.contrib.ZipInputStreamSource$$anon$1.class
akka.stream.contrib.SourceGen$$anonfun$2$$anon$2$$anon$4.class
akka.stream.contrib.Retry$$anonfun$apply$1.class
akka.stream.contrib.Sample$.class
akka.stream.contrib.Retry$RetryCoordinator$$anon$1$$anon$4$$anonfun$onPush$1.class
akka.stream.contrib.TimedOps.class
akka.stream.contrib.DelayFlow$$anonfun$apply$1.class
akka.stream.contrib.LastElement$$anon$1$$anon$2.class
akka.stream.contrib.Retry$$anonfun$concat$1.class
akka.stream.contrib.FileTailSource$2.class
akka.stream.contrib.PartitionWith$$anon$1$$anon$4.class
akka.stream.contrib.Sample.class
akka.stream.contrib.PassThroughFlow.class
akka.stream.contrib.Retry$RetryConcatCoordinator$$anon$6$$anon$7$$anonfun$onUpstreamFinish$1.class
akka.stream.contrib.KeepAliveConcat$$anon$1.class
akka.stream.contrib.Timed$StopTimed$$anon$2.class
akka.stream.contrib.PagedSource$Page.class
akka.stream.contrib.DelayFlow$DelayStrategy$$anonfun$linearIncreasingDelay$1.class
akka.stream.contrib.IntervalBasedRateLimiter.class
akka.stream.contrib.Retry.class
akka.stream.contrib.DirectoryChanges$1.class
akka.stream.contrib.UnfoldFlowGraphStageLogic$$anon$3.class
akka.stream.contrib.PassThroughFlow$$anonfun$apply$1$$anonfun$1.class
akka.stream.contrib.SourceRepeatEval$.class
akka.stream.contrib.PartitionWith$Implicits$FlowGraphOps.class
akka.stream.contrib.PartitionWith$$anon$1$$anon$2.class
akka.stream.contrib.SourceGen$$anonfun$unfoldFlowGraph$1.class
akka.stream.contrib.Implicits$.class
akka.stream.contrib.Pulse.class
akka.stream.contrib.PartitionWith$$anon$1$$anon$4$$anonfun$onPull$2.class
akka.stream.contrib.Sample$$anonfun$random$2.class
akka.stream.contrib.AccumulateWhileUnchanged$$anonfun$create$1.class
akka.stream.contrib.FeedbackLoop$Implicits$FeedbackShapeOps.class
akka.stream.contrib.PassThroughFlow$$anonfun$apply$1.class
akka.stream.contrib.FeedbackLoop$$anon$1.class
akka.stream.contrib.Valve$ValveGraphStageLogic.class
akka.stream.contrib.DelayFlow$DelayStrategy$$anon$2.class
akka.stream.contrib.AccumulateWhileUnchanged$$anon$1$$anon$2.class
akka.stream.contrib.Retry$RetryCoordinator$$anon$1$$anon$4.class
akka.stream.contrib.Retry$$anonfun$concat$1$$anonfun$apply$3.class
akka.stream.contrib.Retry$RetryConcatCoordinator$$anon$6$$anon$10$$anon$11$$anonfun$run$1.class
akka.stream.contrib.FeedbackLoop$Implicits$FanOut2Ops$.class
akka.stream.contrib.Retry$RetryConcatCoordinator$$anon$6$$anon$7.class
akka.stream.contrib.Sample$$anon$1.class
akka.stream.contrib.Retry$RetryConcatCoordinator$$anon$6$$anon$10$$anon$11.class
akka.stream.contrib.FeedbackLoop$$anon$1$$anon$2$$anon$3.class
akka.stream.contrib.PagedSource$$anonfun$1$$anonfun$apply$1.class
akka.stream.contrib.DelayFlow$$anon$1.class
akka.stream.contrib.Pulse$.class
akka.stream.contrib.KeepAliveConcat.class
akka.stream.contrib.PartitionWith$$anonfun$create$1.class
akka.stream.contrib.PartitionWith$Implicits$.class
akka.stream.contrib.AccumulateWhileUnchanged$$anon$1.class
akka.stream.contrib.ZipInputStreamSource$$anon$1$$anonfun$isZipFile$1.class
akka.stream.contrib.Retry$RetryCoordinator$$anon$1$$anon$4$$anonfun$onPush$3.class
akka.stream.contrib.FeedbackLoop$$anon$1$$anon$2.class
akka.stream.contrib.Retry$RetryConcatCoordinator$$anon$6.class
akka.stream.contrib.Sample$$anonfun$apply$1.class
akka.stream.contrib.DelayFlow$DelayStrategy$$anonfun$linearIncreasingDelay$2.class
akka.stream.contrib.SourceGen$$anonfun$unfoldFlowGraph$1$$anonfun$apply$1.class
akka.stream.contrib.DelayFlow$DelayStrategy$.class
akka.stream.contrib.DelayFlow$$anon$1$DelayTimerKey$.class
akka.stream.contrib.AccumulateWhileUnchanged.class
akka.stream.contrib.DelayFlow.class
akka.stream.contrib.PartitionWith.class
akka.stream.contrib.SwitchMode$Open$.class
akka.stream.contrib.UnfoldFlowGraphStageLogic$$anon$1.class
reference.conf
akka.stream.contrib.TimeWindow$.class
akka.stream.contrib.Retry$RetryConcatCoordinator$$anon$6$$anon$10.class
akka.stream.contrib.Implicits$TimedSourceDsl.class
akka.stream.contrib.SwitchMode$.class
akka.stream.contrib.DelayFlow$DelayStrategy$$anon$3.class
akka.stream.contrib.AccumulateWhileUnchanged$.class
akka.stream.contrib.PartitionWith$Implicits$FlowGraphOps$.class
akka.stream.contrib.PartitionWith$$anon$1$$anon$3$$anonfun$onPull$1.class
akka.stream.contrib.SourceRepeatEval.class
akka.stream.contrib.DirectoryChanges$Change.class
akka.stream.contrib.FeedbackLoop$Implicits$FanOut2Ops.class
akka.stream.contrib.LastElement$$anon$1$$anon$3.class
akka.stream.contrib.PagedSource$$anonfun$1.class
akka.stream.contrib.PassThroughFlow$.class
akka.stream.contrib.PartitionWith$.class
akka.stream.contrib.Accumulate$$anonfun$create$1.class
akka.stream.contrib.Pulse$$anon$1.class
akka.stream.contrib.FileTailSource$2$1.class
akka.stream.contrib.Timed$TimedInterval$$anon$3.class
akka.stream.contrib.FileTailSource$1.class
akka.stream.contrib.Valve$ValveGraphStageLogic$$anon$1$$anonfun$2.class
akka.stream.contrib.SourceGen$$anonfun$2$$anon$2.class
akka.stream.contrib.TimedIntervalBetweenOps$class.class
akka.stream.contrib.Accumulate$.class
akka.stream.contrib.PagedSource$.class
akka.stream.contrib.SourceRepeatEval$$anon$1.class
akka.stream.contrib.Implicits$TimedFlowDsl$.class
akka.stream.contrib.Retry$RetryConcatCoordinator$$anon$6$$anon$8.class
akka.stream.contrib.ZipInputStreamSource$ZipEntryData.class
akka.stream.contrib.SourceRepeatEval$$anonfun$nextStep$1$1.class
akka.stream.contrib.Valve$ValveGraphStageLogic$$anon$1$$anonfun$1.class
akka.stream.contrib.UnfoldFlowGraphStageLogic.class
akka.stream.contrib.KeepAliveConcat$.class
akka.stream.contrib.SourceRepeatEval$$anonfun$apply$1.class
akka.stream.contrib.PartitionWith$$anon$1$$anon$3.class
akka.stream.contrib.Retry$RetryCoordinator.class
akka.stream.contrib.SourceGen$$anonfun$1.class
akka.stream.contrib.UnfoldFlowGraphStageLogic$$anon$1$$anon$2$$anonfun$run$1.class
akka.stream.contrib.Implicits$TimedSourceDsl$.class
akka.stream.contrib.SwitchMode$Close$.class
akka.stream.contrib.PartitionWith$Implicits$FlowGraphOps$$anonfun$partitionWith$extension$1.class
akka.stream.contrib.TimeWindow.class
akka.stream.contrib.Accumulate$$anon$1$$anon$3.class
akka.stream.contrib.Valve$ValveGraphStageLogic$$anon$1.class
akka.stream.contrib.Accumulate.class
akka.stream.contrib.Sample$$anonfun$random$1.class
akka.stream.contrib.Retry$RetryConcatCoordinator.class
akka.stream.contrib.FanOut2unfoldingStage.class
akka.stream.contrib.FeedbackLoop$$anonfun$apply$1.class
akka.stream.contrib.Timed$TimedFlowContext.class
akka.stream.contrib.TimedOps$class.class
akka.stream.contrib.LastElement$.class
akka.stream.contrib.PartitionWith$Implicits$FlowGraphOps$$anonfun$partitionWith$extension$1$$anonfun$apply$1.class
akka.stream.contrib.ZipInputStreamSource.class
akka.stream.contrib.DelayFlow$DelayStrategy.class
akka.stream.contrib.ValveSwitch.class
akka.stream.contrib.ZipInputStreamSource$$anon$1$$anon$2.class
akka.stream.contrib.Retry$RetryConcatCoordinator$$anon$6$$anon$9$$anonfun$onPush$4$$anonfun$apply$4.class
akka.stream.contrib.SwitchMode.class
akka.stream.contrib.Sample$$anon$1$$anonfun$getNextStep$1.class
#内容未全部加载，请点击展开加载全部代码(NowJava.com)