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

Mima and internalizing things that should have already been internal

Browse source
This commit is contained in:
Johan Andrén 2017-10-13 17:18:28 +02:00
parent 1c35429a9b
commit c830a75bd0
2 changed files with 8 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-stream/src/main/scala/akka/stream/javadsl/Tcp.scala
View file

@ -25,14 +25,16 @@ import scala.compat.java8.OptionConverters._
import scala.compat.java8.FutureConverters._
import java.util.concurrent.CompletionStage
import scala.concurrent.Future
import akka.annotation.InternalApi
object Tcp extends ExtensionId[Tcp] with ExtensionIdProvider {
/**
* Represents a prospective TCP server binding.
*
* Not indented for user construction
*/
class ServerBinding private[akka] (delegate: scaladsl.Tcp.ServerBinding) {
final class ServerBinding @InternalApi private[akka] (delegate: scaladsl.Tcp.ServerBinding) {
/**
* The local address of the endpoint bound by the materialization of the `connections` [[Source]].
*/

5
akka-stream/src/main/scala/akka/stream/scaladsl/Tcp.scala
View file

@ -8,6 +8,7 @@ import java.util.concurrent.TimeoutException
import akka.{ Done, NotUsed }
import akka.actor._
import akka.annotation.InternalApi
import akka.io.Inet.SocketOption
import akka.io.{ IO, Tcp ⇒ IoTcp }
import akka.stream._
@ -28,8 +29,10 @@ object Tcp extends ExtensionId[Tcp] with ExtensionIdProvider {
* @param localAddress The address the server was bound to
* @param unbindAction a function that will trigger unbind of the server
* @param whenUnbound A future that is completed when the server is unbound, or failed if the server binding fails
*
* Not indented for user construction
*/
final case class ServerBinding(localAddress: InetSocketAddress)(
final case class ServerBinding @InternalApi private[akka] (localAddress: InetSocketAddress)(
private val unbindAction: () ⇒ Future[Unit],
val whenUnbound: Future[Done]
) {