Searched refs:serverStream (Results 1 – 8 of 8) sorted by relevance
376 ServerStream serverStream = serverStreamCreation.stream; in openStreamPreventsTermination() local397 serverStream.writeHeaders(new Metadata()); in openStreamPreventsTermination()701 ServerStream serverStream = serverStreamCreation.stream; in basicStream() local708 serverStream.getAttributes().get(ADDITIONAL_TRANSPORT_ATTR_KEY)); in basicStream()709 assertNotNull(serverStream.getAttributes().get(Grpc.TRANSPORT_ATTR_REMOTE_ADDR)); in basicStream()711 serverStream.request(1); in basicStream()753 serverStream.writeHeaders(serverHeaders); in basicStream()765 assertTrue(serverStream.isReady()); in basicStream()766 serverStream.writeMessage(methodDescriptor.streamResponse("Hi. Who are you?")); in basicStream()769 serverStream.flush(); in basicStream()[all …]
463 NettyServerStream.TransportState stream = serverStream(requireHttp2Stream(streamId)); in onDataRead()474 NettyServerStream.TransportState stream = serverStream(connection().stream(streamId)); in onRstStreamRead()498 NettyServerStream.TransportState serverStream = serverStream( in onStreamError() local500 if (serverStream != null) { in onStreamError()501 serverStream.transportReportStatus(Utils.statusFromThrowable(cause)); in onStreamError()550 NettyServerStream.TransportState serverStream = serverStream(stream); in channelInactive()551 if (serverStream != null) { in channelInactive()552 serverStream.transportReportStatus(status); in channelInactive()601 final NettyServerStream.TransportState stream = serverStream(requireHttp2Stream(streamId)); in closeStreamWhenDone()655 NettyServerStream.TransportState serverStream = serverStream(stream); in forcefulClose()[all …]
271 private final InProcessServerStream serverStream;283 this.serverStream = new InProcessServerStream(method, headers);525 boolean onReady = serverStream.clientRequested(numMessages);570 serverStream.statsTraceCtx.inboundMessage(outboundSeqNo);571 serverStream.statsTraceCtx.inboundMessageRead(outboundSeqNo, -1, -1);600 serverStream.clientCancelled(reason);622 serverStream.statsTraceCtx.streamClosed(serverTracerStatus);649 serverStream.setListener(listener);657 serverTransportListener.streamCreated(serverStream, method.getFullMethodName(), headers);
647 type serverStream struct { struct668 func (ss *serverStream) Context() context.Context { argument672 func (ss *serverStream) SetHeader(md metadata.MD) error { argument679 func (ss *serverStream) SendHeader(md metadata.MD) error { argument683 func (ss *serverStream) SetTrailer(md metadata.MD) { argument690 func (ss *serverStream) SendMsg(m interface{}) (err error) { argument734 func (ss *serverStream) RecvMsg(m interface{}) (err error) { argument
1102 ss := &serverStream{
META-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...
META-INF/ META-INF/MANIFEST.MF com/ com/db4o/ com/ ...