override fun onNext()

in plugin-bazel-event-service/src/main/kotlin/bazel/BesGrpcServerEventStream.kt [59:80]

• 20 lines of code
• 3 McCabe index (conditional complexity)

        override fun onNext(value: PublishBuildToolEventStreamRequest) {
            // send response
            _responseObserver.onNext(
                PublishBuildToolEventStreamResponse
                    .newBuilder()
                    .setSequenceNumber(value.orderedBuildEventOrBuilder.sequenceNumber)
                    .setStreamId(value.orderedBuildEventOrBuilder.streamId)
                    .build(),
            )

            if (value.hasOrderedBuildEvent() && value.orderedBuildEvent.hasEvent()) {
                onEvent(
                    Result.Event(
                        value.orderedBuildEvent.sequenceNumber,
                        value.orderedBuildEvent.streamId,
                        value.orderedBuildEvent.event,
                    ),
                )
            } else {
                messageWriter.error("OrderedBuildEvent was not found.")
            }
        }