Searched refs:connectExchange (Results 1 – 8 of 8) sorted by relevance
76 Exchange<Void> connectExchange = mulEx.getExchange(); in connectAsync() local78 return connectExchange in connectAsync()84 return connectExchange.ignoreBody().handle((r,t) -> { in connectAsync()99 … ByteBuffer b = ((Http1Exchange<?>)connectExchange.exchImpl).drainLeftOverBytes(); in connectAsync()
77 Exchange<Void> connectExchange = mulEx.getExchange(); in connectAsync() local79 return connectExchange in connectAsync()85 return connectExchange.ignoreBody().handle((r,t) -> { in connectAsync()100 … ByteBuffer b = ((Http1Exchange<?>)connectExchange.exchImpl).drainLeftOverBytes(); in connectAsync()