Searched refs:clientStream (Results 1 – 8 of 8) sorted by relevance
370 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in openStreamPreventsTermination() local372 clientStream.start(clientStreamListener); in openStreamPreventsTermination()398 clientStream.halfClose(); in openStreamPreventsTermination()406 clientStream.cancel(Status.CANCELLED); in openStreamPreventsTermination()422 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in shutdownNowKillsClientStream() local424 clientStream.start(clientStreamListener); in shutdownNowKillsClientStream()459 ClientStream clientStream = client.newStream(methodDescriptor, new Metadata(), callOptions); in shutdownNowKillsServerStream() local461 clientStream.start(clientStreamListener); in shutdownNowKillsServerStream()687 ClientStream clientStream = client.newStream(methodDescriptor, clientHeaders, callOptions); in basicStream() local692 clientStream.start(clientStreamListener); in basicStream()[all …]
78 CronetClientStream clientStream; field in CronetClientStreamTest108 clientStream = in setUp()123 callback.setStream(clientStream); in setUp()128 clientStream.start(clientListener); in setUp()166 clientStream.abstractClientStreamSink().writeFrame(buffers[i], false, i == 2 || i == 4, 1); in write()191 clientStream.abstractClientStreamSink().writeFrame(null, true, true, 1); in write()263 clientStream.request(1); in read()268 clientStream.request(1); in read()290 clientStream.abstractClientStreamSink().writeFrame(writableBuffer, false, true, 1); in streamSucceeded()298 clientStream.request(2); in streamSucceeded()[all …]
161 return new InProcessStream(method, headers, callOptions, authority).clientStream;214 stream.clientStream.cancel(reason);271 private final InProcessClientStream clientStream;283 this.clientStream = new InProcessClientStream(callOptions, headers);330 clientStream.setListener(serverStreamListener);335 boolean onReady = clientStream.serverRequested(numMessages);367 clientStream.statsTraceCtx.streamClosed(clientNotifyStatus);385 clientStream.statsTraceCtx.inboundMessage(outboundSeqNo);386 clientStream.statsTraceCtx.inboundMessageRead(outboundSeqNo, -1, -1);413 clientStream.statsTraceCtx.clientInboundHeaders();[all …]
342 NettyClientStream.TransportState stream = clientStream(requireHttp2Stream(streamId)); in onHeadersRead()354 NettyClientStream.TransportState stream = clientStream(requireHttp2Stream(streamId)); in onDataRead()366 NettyClientStream.TransportState stream = clientStream(connection().stream(streamId)); in onRstStreamRead()407 NettyClientStream.TransportState clientStream = clientStream(stream); in channelInactive()408 if (clientStream != null) { in channelInactive()409 clientStream.transportReportStatus( in channelInactive()463 NettyClientStream.TransportState stream = clientStream(connection().stream(http2Ex.streamId())); in onStreamError()654 NettyClientStream.TransportState clientStream = clientStream(stream); in forcefulClose()655 if (clientStream != null) { in forcefulClose()656 clientStream.transportReportStatus(msg.getStatus(), true, new Metadata()); in forcefulClose()[all …]
121 final CronetClientStream clientStream = new CronetClientStream( in newStream() field in CronetClientTransport.StartCallback129 clientStream.transportState().transportReportStatus(goAwayStatus, true, new Metadata()); in newStream()131 startStream(clientStream); in newStream()139 return new StartCallback().clientStream; in newStream()
40 clientStream, err := clientSession.OpenStreamSync()44 _, err = clientStream.Write(msg)
354 void streamReadyToStart(OkHttpClientStream clientStream) { in streamReadyToStart() argument356 clientStream.transportState().transportReportStatus( in streamReadyToStart()359 pendingStreams.add(clientStream); in streamReadyToStart()362 startStream(clientStream); in streamReadyToStart()
META-INF/ META-INF/MANIFEST.MF com/ com/db4o/ com/ ...