raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

!str rename SPI/TCK to org.reactivestreams

Browse source
This commit is contained in:
Roland Kuhn 2014-03-28 14:33:33 +01:00
parent 156b661bfc
commit c8f462d6e6
11 changed files with 24 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/Stream.scala
View file

@ -4,7 +4,7 @@
package akka.stream package akka.stream
import scala.collection.immutable import scala.collection.immutable
import asyncrx.api.{ Consumer, Producer } import org.reactivestreams.api.{ Consumer, Producer }
import scala.util.control.NonFatal import scala.util.control.NonFatal
import akka.stream.impl._ import akka.stream.impl._
import akka.actor.ActorRefFactory import akka.actor.ActorRefFactory

4
akka-stream/src/main/scala/akka/stream/impl/AbstractProducer.scala
View file

@ -4,8 +4,8 @@
package akka.stream.impl package akka.stream.impl
import scala.annotation.tailrec import scala.annotation.tailrec
import asyncrx.api import org.reactivestreams.api
import asyncrx.spi import org.reactivestreams.spi
import SubscriberManagement.ShutDown import SubscriberManagement.ShutDown
import ResizableMultiReaderRingBuffer.NothingToReadException import ResizableMultiReaderRingBuffer.NothingToReadException

4
akka-stream/src/main/scala/akka/stream/impl/StreamImpl.scala
View file

@ -3,9 +3,9 @@
*/ */
package akka.stream.impl package akka.stream.impl
import asyncrx.api.{ Producer, Consumer, Processor } import org.reactivestreams.api.{ Producer, Consumer, Processor }
import akka.actor.{ Actor, ActorRef, ActorRefFactory, Props, PoisonPill } import akka.actor.{ Actor, ActorRef, ActorRefFactory, Props, PoisonPill }
import asyncrx.spi.{ Publisher, Subscription, Subscriber } import org.reactivestreams.spi.{ Publisher, Subscription, Subscriber }
import java.util.concurrent.atomic.AtomicReference import java.util.concurrent.atomic.AtomicReference
import scala.annotation.tailrec import scala.annotation.tailrec
import scala.util.control.NonFatal import scala.util.control.NonFatal

4
akka-stream/src/main/scala/akka/stream/impl/StrictProducer.scala
View file

@ -6,8 +6,8 @@ package akka.stream.impl
import java.util.concurrent.atomic.AtomicBoolean import java.util.concurrent.atomic.AtomicBoolean
import scala.annotation.tailrec import scala.annotation.tailrec
import scala.concurrent.ExecutionContext import scala.concurrent.ExecutionContext
import asyncrx.spi import org.reactivestreams.spi
import asyncrx.api.Consumer import org.reactivestreams.api.Consumer
/** /**
* INTERNAL API * INTERNAL API

6
akka-stream/src/test/scala/akka/stream/IdentityProcessorTest.scala
View file

@ -4,9 +4,9 @@
package akka.stream package akka.stream
import org.scalatest.testng.TestNGSuiteLike import org.scalatest.testng.TestNGSuiteLike
import asyncrx.spi.Publisher import org.reactivestreams.spi.Publisher
import asyncrx.api.Processor import org.reactivestreams.api.Processor
import asyncrx.tck.IdentityProcessorVerification import org.reactivestreams.tck.IdentityProcessorVerification
import akka.actor.Props import akka.actor.Props
import akka.stream.impl.ActorProcessor import akka.stream.impl.ActorProcessor
import akka.stream.impl.TransformProcessorImpl import akka.stream.impl.TransformProcessorImpl

4
akka-stream/src/test/scala/akka/stream/IteratorProducerTest.scala
View file

@ -4,8 +4,8 @@
package akka.stream package akka.stream
import org.scalatest.testng.TestNGSuiteLike import org.scalatest.testng.TestNGSuiteLike
import asyncrx.spi.Publisher import org.reactivestreams.spi.Publisher
import asyncrx.tck.PublisherVerification import org.reactivestreams.tck.PublisherVerification
import akka.stream.testkit.TestProducer import akka.stream.testkit.TestProducer
class IteratorProducerTest extends PublisherVerification[Int] with WithActorSystem with TestNGSuiteLike { class IteratorProducerTest extends PublisherVerification[Int] with WithActorSystem with TestNGSuiteLike {

2
akka-stream/src/test/scala/akka/stream/StreamSpec.scala
View file

@ -6,7 +6,7 @@ package akka.stream
import scala.concurrent.duration._ import scala.concurrent.duration._
import akka.stream.testkit.StreamTestKit import akka.stream.testkit.StreamTestKit
import akka.testkit._ import akka.testkit._
import asyncrx.api.Producer import org.reactivestreams.api.Producer
import org.scalatest.FreeSpecLike import org.scalatest.FreeSpecLike
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner]) @org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])

4
akka-stream/src/test/scala/akka/stream/testkit/ConsumerProbe.scala
View file

@ -4,8 +4,8 @@
package akka.stream.testkit package akka.stream.testkit
import scala.concurrent.duration.FiniteDuration import scala.concurrent.duration.FiniteDuration
import asyncrx.api.Consumer import org.reactivestreams.api.Consumer
import asyncrx.spi.Subscription import org.reactivestreams.spi.Subscription
sealed trait ConsumerEvent sealed trait ConsumerEvent
case class OnSubscribe(subscription: Subscription) extends ConsumerEvent case class OnSubscribe(subscription: Subscription) extends ConsumerEvent

6
akka-stream/src/test/scala/akka/stream/testkit/ProducerProbe.scala
View file

@ -3,10 +3,10 @@
*/ */
package akka.stream.testkit package akka.stream.testkit
import asyncrx.spi.{ Subscriber, Subscription } import org.reactivestreams.spi.{ Subscriber, Subscription }
import asyncrx.api.Producer import org.reactivestreams.api.Producer
import scala.concurrent.duration.FiniteDuration import scala.concurrent.duration.FiniteDuration
import asyncrx.api.Consumer import org.reactivestreams.api.Consumer
sealed trait ProducerEvent sealed trait ProducerEvent
case class Subscribe(subscription: Subscription) extends ProducerEvent case class Subscribe(subscription: Subscription) extends ProducerEvent

4
akka-stream/src/test/scala/akka/stream/testkit/StreamTestKit.scala
View file

@ -4,8 +4,8 @@
package akka.stream.testkit package akka.stream.testkit
import akka.testkit.TestProbe import akka.testkit.TestProbe
import asyncrx.spi.{ Publisher, Subscriber, Subscription } import org.reactivestreams.spi.{ Publisher, Subscriber, Subscription }
import asyncrx.tck._ import org.reactivestreams.tck._
import akka.actor.ActorSystem import akka.actor.ActorSystem
import scala.concurrent.duration.FiniteDuration import scala.concurrent.duration.FiniteDuration
import scala.annotation.tailrec import scala.annotation.tailrec

8
akka-stream/src/test/scala/akka/stream/testkit/TestProducer.scala
View file

@ -3,12 +3,12 @@
*/ */
package akka.stream.testkit package akka.stream.testkit
import asyncrx.api.Producer import org.reactivestreams.api.Producer
import akka.stream.impl.IteratorProducer import akka.stream.impl.IteratorProducer
import scala.concurrent.ExecutionContext import scala.concurrent.ExecutionContext
import asyncrx.spi.Subscriber import org.reactivestreams.spi.Subscriber
import asyncrx.spi.Publisher import org.reactivestreams.spi.Publisher
import asyncrx.api.Consumer import org.reactivestreams.api.Consumer
object TestProducer { object TestProducer {
def apply[T](iterable: Iterable[T])(implicit executor: ExecutionContext): Producer[T] = apply(iterable.iterator) def apply[T](iterable: Iterable[T])(implicit executor: ExecutionContext): Producer[T] = apply(iterable.iterator)