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

still finding some stray akka refs (#441)

Browse source
This commit is contained in:
PJ Fanning 2023-06-21 12:52:59 +01:00 • committed by GitHub
parent eea42b8741
commit 279d65a7fa
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
5 changed files with 8 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

6
distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/ORMap.scala
View file

@ -230,7 +230,7 @@ final class ORMap[A, B <: ReplicatedData] private[pekko] (
/** /**
* Adds an entry to the map * Adds an entry to the map
* @see [[ORMap#put(node:akka\.cluster\.ddata\.SelfUniqueAddress*]] * @see [[ORMap#put(node:org\.apache\.pekko\.cluster\.ddata\.SelfUniqueAddress*]]
*/ */
def :+(entry: (A, B))(implicit node: SelfUniqueAddress): ORMap[A, B] = { def :+(entry: (A, B))(implicit node: SelfUniqueAddress): ORMap[A, B] = {
val (key, value) = entry val (key, value) = entry
@ -249,13 +249,13 @@ final class ORMap[A, B <: ReplicatedData] private[pekko] (
* on other nodes and the outcome depends on what `ReplicatedData` * on other nodes and the outcome depends on what `ReplicatedData`
* type that is used. * type that is used.
* *
* Consider using [[ORMap#updated(node:akka\.cluster\.ddata\.SelfUniqueAddress*]] * Consider using [[ORMap#updated(node:org\.apache\.pekko\.cluster\.ddata\.SelfUniqueAddress*]]
* instead of `put` if you want modify existing entry. * instead of `put` if you want modify existing entry.
* *
* `IllegalArgumentException` is thrown if you try to replace an existing `ORSet` * `IllegalArgumentException` is thrown if you try to replace an existing `ORSet`
* value, because important history can be lost when replacing the `ORSet` and * value, because important history can be lost when replacing the `ORSet` and
* undesired effects of merging will occur. Use [[ORMultiMap]] or * undesired effects of merging will occur. Use [[ORMultiMap]] or
* [[ORMap#updated(node:akka\.cluster\.ddata\.SelfUniqueAddress*]] instead. * [[ORMap#updated(node:org\.apache\.pekko\.cluster\.ddata\.SelfUniqueAddress*]] instead.
*/ */
def put(node: SelfUniqueAddress, key: A, value: B): ORMap[A, B] = put(node.uniqueAddress, key, value) def put(node: SelfUniqueAddress, key: A, value: B): ORMap[A, B] = put(node.uniqueAddress, key, value)

4
distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/ORMultiMap.scala
View file

@ -148,7 +148,7 @@ final class ORMultiMap[A, B] private[pekko] (
/** /**
* Convenience for put. Requires an implicit SelfUniqueAddress. * Convenience for put. Requires an implicit SelfUniqueAddress.
* @see [[ORMultiMap#put(node:akka\.cluster\.ddata\.SelfUniqueAddress,key:A,value:Set*]] * @see [[ORMultiMap#put(node:org\.apache\.pekko\.cluster\.ddata\.SelfUniqueAddress,key:A,value:Set*]]
*/ */
def :+(entry: (A, Set[B]))(implicit node: SelfUniqueAddress): ORMultiMap[A, B] = { def :+(entry: (A, Set[B]))(implicit node: SelfUniqueAddress): ORMultiMap[A, B] = {
val (key, value) = entry val (key, value) = entry
@ -207,7 +207,7 @@ final class ORMultiMap[A, B] private[pekko] (
/** /**
* Convenience for remove. Requires an implicit Cluster. * Convenience for remove. Requires an implicit Cluster.
* @see [[ORMultiMap#remove(node:akka\.cluster\.ddata\.SelfUniqueAddress*]] * @see [[ORMultiMap#remove(node:org\.apache\.pekko\.cluster\.ddata\.SelfUniqueAddress*]]
*/ */
@deprecated("Use `remove` that takes a `SelfUniqueAddress` parameter instead.", since = "Akka 2.5.20") @deprecated("Use `remove` that takes a `SelfUniqueAddress` parameter instead.", since = "Akka 2.5.20")
def -(key: A)(implicit node: Cluster): ORMultiMap[A, B] = remove(node.selfUniqueAddress, key) def -(key: A)(implicit node: Cluster): ORMultiMap[A, B] = remove(node.selfUniqueAddress, key)

2
distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/ORSet.scala
View file

@ -417,7 +417,7 @@ final class ORSet[A] private[pekko] (
/** /**
* Removes all elements from the set, but keeps the history. * Removes all elements from the set, but keeps the history.
* This has the same result as using * This has the same result as using
* [[ORSet#remove(node:akka\.cluster\.ddata\.SelfUniqueAddress*]] * [[ORSet#remove(node:org\.apache\.pekko\.cluster\.ddata\.SelfUniqueAddress*]]
* for each element, but it is more efficient. * for each element, but it is more efficient.
*/ */
def clear(@unused node: SelfUniqueAddress): ORSet[A] = clear() def clear(@unused node: SelfUniqueAddress): ORSet[A] = clear()

2
stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowSpec.scala
View file

@ -45,7 +45,7 @@ object FlowSpec {
} }
@nowarn // tests type assignments compile @nowarn // tests type assignments compile
class FlowSpec extends StreamSpec(ConfigFactory.parseString("pekko.actor.debug.receive=off\nakka.loglevel=INFO")) { class FlowSpec extends StreamSpec(ConfigFactory.parseString("pekko.actor.debug.receive=off\npekko.loglevel=INFO")) {
import FlowSpec._ import FlowSpec._
val settings = ActorMaterializerSettings(system).withInputBuffer(initialSize = 2, maxSize = 2) val settings = ActorMaterializerSettings(system).withInputBuffer(initialSize = 2, maxSize = 2)

2
stream/src/main/scala/org/apache/pekko/stream/impl/streamref/SinkRefImpl.scala
View file

@ -123,7 +123,7 @@ private[stream] final class SinkRefStageImpl[In] private[pekko] (val initialPart
observeAndValidateSender( observeAndValidateSender(
ref, ref,
"Illegal initialPartnerRef! This may be a bug, please report your " + "Illegal initialPartnerRef! This may be a bug, please report your " +
"usage and complete stack trace on the issue tracker: https://github.com/akka/akka") "usage and complete stack trace on the issue tracker: https://github.com/apache/incubator-pekko")
tryPull() tryPull()
case _ => case _ =>
log.debug( log.debug(