* limitations under the License.
*/
-#include <folly/wangle/channel/ChannelPipeline.h>
+#include <folly/wangle/channel/Pipeline.h>
#include <folly/wangle/channel/OutputBufferingHandler.h>
-#include <folly/wangle/channel/test/MockChannelHandler.h>
+#include <folly/wangle/channel/test/MockHandler.h>
#include <folly/io/async/AsyncSocket.h>
#include <gmock/gmock.h>
#include <gtest/gtest.h>
using namespace folly::wangle;
using namespace testing;
-typedef StrictMock<MockChannelHandlerAdapter<
+typedef StrictMock<MockHandlerAdapter<
IOBufQueue&,
std::unique_ptr<IOBuf>>>
-MockHandler;
+MockBytesHandler;
MATCHER_P(IOBufContains, str, "") { return arg->moveToFbString() == str; }
TEST(OutputBufferingHandlerTest, Basic) {
- MockHandler mockHandler;
+ MockBytesHandler mockHandler;
EXPECT_CALL(mockHandler, attachPipeline(_));
- ChannelPipeline<IOBufQueue&, std::unique_ptr<IOBuf>,
- ChannelHandlerPtr<MockHandler, false>,
+ Pipeline<IOBufQueue&, std::unique_ptr<IOBuf>,
+ HandlerPtr<MockBytesHandler, false>,
OutputBufferingHandler>
pipeline(&mockHandler, OutputBufferingHandler{});