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

Fix StreamRefSerializer.serializeRemoteSinkFailure throwing NPE (#31307)

Browse source
This commit is contained in:
Paweł Kaczor 2022-04-04 15:36:42 +02:00 • committed by GitHub
parent 36259079aa
commit 30ff7866ee
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-stream/src/main/scala/akka/stream/serialization/StreamRefSerializer.scala
View file

@ -91,7 +91,10 @@ private[akka] final class StreamRefSerializer(val system: ExtendedActorSystem)
d: StreamRefsProtocol.RemoteStreamFailure): StreamRefMessages.RemoteStreamFailure = { d: StreamRefsProtocol.RemoteStreamFailure): StreamRefMessages.RemoteStreamFailure = {
StreamRefMessages.RemoteStreamFailure StreamRefMessages.RemoteStreamFailure
.newBuilder() .newBuilder()
.setCause(UnsafeByteOperations.unsafeWrap(d.msg.getBytes(StandardCharsets.UTF_8))) .setCause {
val msg = Option(d.msg).getOrElse(d.getClass.getName)
UnsafeByteOperations.unsafeWrap(msg.getBytes(StandardCharsets.UTF_8))
}
.build() .build()
} }