Searched refs:capnpToKj (Results 1 – 12 of 12) sorted by relevance
58 auto wrapped = factory1.capnpToKj(factory2.kjToCapnp(kj::mv(pipe.out)));110 auto wrapped = factory.capnpToKj(factory.kjToCapnp(kj::mv(pipe.out)));152 auto wrapped = factory.capnpToKj(factory.kjToCapnp(153 factory.capnpToKj(factory.kjToCapnp(kj::mv(pipe.out)))));196 auto backWrapped = factory.capnpToKj(factory.kjToCapnp(kj::mv(backPipe.out)));199 auto wrapped = factory.capnpToKj(factory.kjToCapnp(kj::mv(middlePipe.out)));467 auto backWrapped = factory.capnpToKj(factory.kjToCapnp(kj::mv(backPipe.out)));469 auto wrapped1 = factory.capnpToKj(factory.kjToCapnp(kj::mv(middlePipe1.out)));470 auto wrapped2 = factory.capnpToKj(factory.kjToCapnp(kj::mv(middlePipe2.out)));534 auto backWrapped = factory.capnpToKj(factory.kjToCapnp(kj::mv(backPipe.out)));[all …]
36 kj::Own<kj::AsyncOutputStream> capnpToKj(capnp::ByteStream::Client capnpStream);
37 kj::Own<kj::HttpService> capnpToKj(capnp::HttpService::Client rpcService);
351 auto frontCapnp = clientFactory.capnpToKj(backCapnp); in runEndToEndTests()460 auto front = clientFactory.capnpToKj(back); in runWebSocketTests()
365 auto bodyOut = factory.streamFactory.capnpToKj(pipeline.getRequestBody()); in request()397 kj::Own<kj::HttpService> HttpOverCapnpFactory::capnpToKj(capnp::HttpService::Client rpcService) { in capnpToKj() function in capnp::HttpOverCapnpFactory509 auto result = factory.streamFactory.capnpToKj(pipeline.getBody()); in send()
997 kj::Own<kj::AsyncOutputStream> ByteStreamFactory::capnpToKj(capnp::ByteStream::Client capnpStream) { in capnpToKj() function in capnp::ByteStreamFactory
68 auto wrapped = factory1.capnpToKj(factory2.kjToCapnp(kj::mv(pipe.out)));156 auto wrapped = factory.capnpToKj(factory.kjToCapnp(kj::mv(pipe.out)));198 auto wrapped = factory.capnpToKj(factory.kjToCapnp(199 factory.capnpToKj(factory.kjToCapnp(kj::mv(pipe.out)))));242 auto backWrapped = factory.capnpToKj(factory.kjToCapnp(kj::mv(backPipe.out)));245 auto wrapped = factory.capnpToKj(factory.kjToCapnp(kj::mv(middlePipe.out)));513 auto backWrapped = factory.capnpToKj(factory.kjToCapnp(kj::mv(backPipe.out)));515 auto wrapped1 = factory.capnpToKj(factory.kjToCapnp(kj::mv(middlePipe1.out)));516 auto wrapped2 = factory.capnpToKj(factory.kjToCapnp(kj::mv(middlePipe2.out)));580 auto backWrapped = factory.capnpToKj(factory.kjToCapnp(kj::mv(backPipe.out)));[all …]
55 kj::Own<kj::HttpService> capnpToKj(capnp::HttpService::Client rpcService);
351 auto frontCapnp = clientFactory.capnpToKj(backCapnp); in runEndToEndTests()450 auto frontCapnp = factory.capnpToKj(backCapnp);525 auto front = clientFactory.capnpToKj(back); in runWebSocketTests()
372 auto bodyOut = factory.streamFactory.capnpToKj(pipeline.getRequestBody()); in request()404 kj::Own<kj::HttpService> HttpOverCapnpFactory::capnpToKj(capnp::HttpService::Client rpcService) { in capnpToKj() function in capnp::HttpOverCapnpFactory513 auto result = factory.streamFactory.capnpToKj(pipeline.getBody()); in send()
1025 kj::Own<kj::AsyncOutputStream> ByteStreamFactory::capnpToKj(capnp::ByteStream::Client capnpStream) { in capnpToKj() function in capnp::ByteStreamFactory