V
Size: a a a
V
АФ
АФ
NM
А
jj
V
АФ
V
jj
jj
AK
def requestStreamResponseV1: ServerStreamStartActionBuilder[StreamRequestV1, StreamResponseV1] =в ответе получаю
grpc("Stream_stream_response")
.serverStream("ServiceStub")
.start(ServiceGrpc.METHOD_STREAM_V1)(StreamRequestV1.defaultInstance)
.extract(_.data.some)(_ saveAs "data")
.timestampExtractor { (session, message, streamStartTime) =>
if (session("data").asOption[Data] == Some(Data.some)) {
throw new IllegalStateException("Message after DONE")
}
if (message.data == Data.some) streamStartTime else TimestampExtractor.IgnoreMessage
}
A
S
ВС
AK
A
ВС