Searched refs:serverStream (Results 1 – 5 of 5) 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()710 assertNotNull(serverStream.getAttributes().get(Grpc.TRANSPORT_ATTR_LOCAL_ADDR)); in basicStream()712 serverStream.request(1); in basicStream()754 serverStream.writeHeaders(serverHeaders); in basicStream()766 assertTrue(serverStream.isReady()); in basicStream()767 serverStream.writeMessage(methodDescriptor.streamResponse("Hi. Who are you?")); 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 …]
272 private final InProcessServerStream serverStream;284 this.serverStream = new InProcessServerStream(method, headers);526 boolean onReady = serverStream.clientRequested(numMessages);571 serverStream.statsTraceCtx.inboundMessage(outboundSeqNo);572 serverStream.statsTraceCtx.inboundMessageRead(outboundSeqNo, -1, -1);601 serverStream.clientCancelled(reason);623 serverStream.statsTraceCtx.streamClosed(serverTracerStatus);650 serverStream.setListener(listener);658 serverTransportListener.streamCreated(serverStream, method.getFullMethodName(), headers);
65 serverStream := <-serverStreams67 _, err = io.ReadFull(serverStream, b)
META-INF/ META-INF/MANIFEST.MF com/ com/db4o/ com/ ...