Skip to content

Commit 60a7796

Browse files
committed
Formatting
1 parent 38cbced commit 60a7796

File tree

3 files changed

+27
-25
lines changed

3 files changed

+27
-25
lines changed

anthropic-client/src/main/scala/io/cequence/openaiscala/anthropic/service/impl/AwsEventStreamBytesDecoder.scala

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -11,15 +11,15 @@ object AwsEventStreamBytesDecoder {
1111
// eventJson might look like:
1212
// { ":message-type":"event", ":event-type":"...", "bytes":"base64string" }
1313

14-
val base64Str = (eventJson \ "bytes").asOpt[String]
15-
base64Str match {
16-
case Some(encoded) =>
14+
(eventJson \ "bytes")
15+
.asOpt[String]
16+
.map { encoded =>
1717
val decoded = Base64.getDecoder.decode(encoded)
1818
Json.parse(decoded)
19-
case None =>
19+
}
20+
.getOrElse(
2021
// If there's no "bytes" field, return the original JSON (or handle differently)
2122
eventJson
22-
}
23+
)
2324
}
2425
}
25-

anthropic-client/src/main/scala/io/cequence/openaiscala/anthropic/service/impl/AwsEventStreamEventParser.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,4 +17,3 @@ object AwsEventStreamEventParser {
1717
None
1818
}
1919
}
20-

anthropic-client/src/main/scala/io/cequence/openaiscala/anthropic/service/impl/AwsEventStreamFrameDecoder.scala

Lines changed: 21 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -14,30 +14,33 @@ class AwsEventStreamFrameDecoder extends GraphStage[FlowShape[ByteString, ByteSt
1414
override def createLogic(attrs: Attributes): GraphStageLogic = new GraphStageLogic(shape) {
1515
var buffer = ByteString.empty
1616

17-
setHandler(in, new InHandler {
18-
override def onPush(): Unit = {
19-
buffer ++= grab(in)
20-
emitFrames()
21-
}
22-
override def onUpstreamFinish(): Unit = {
23-
emitFrames()
24-
if (buffer.isEmpty) completeStage()
25-
else failStage(new RuntimeException("Truncated frame at stream end"))
17+
setHandler(
18+
in,
19+
new InHandler {
20+
override def onPush(): Unit = {
21+
buffer ++= grab(in)
22+
emitFrames()
23+
}
24+
override def onUpstreamFinish(): Unit = {
25+
emitFrames()
26+
if (buffer.isEmpty) completeStage()
27+
else failStage(new RuntimeException("Truncated frame at stream end"))
28+
}
2629
}
27-
})
30+
)
2831

29-
setHandler(out, new OutHandler {
30-
override def onPull(): Unit = {
31-
if (!hasBeenPulled(in)) pull(in)
32+
setHandler(
33+
out,
34+
new OutHandler {
35+
override def onPull(): Unit = {
36+
if (!hasBeenPulled(in)) pull(in)
37+
}
3238
}
33-
})
39+
)
3440

3541
def emitFrames(): Unit = {
3642
while (buffer.size >= 4) {
3743
val totalLength = buffer.iterator.getInt
38-
println("buffer size: " + buffer.size)
39-
println("total length: " + totalLength)
40-
println("buffer: " + buffer.utf8String)
4144

4245
if (buffer.size < 4 + totalLength) {
4346
// not enough data yet
@@ -53,4 +56,4 @@ class AwsEventStreamFrameDecoder extends GraphStage[FlowShape[ByteString, ByteSt
5356
}
5457
}
5558
}
56-
}
59+
}

0 commit comments

Comments
 (0)