Index: mojo/public/cpp/bindings/lib/router.cc |
diff --git a/mojo/public/cpp/bindings/lib/router.cc b/mojo/public/cpp/bindings/lib/router.cc |
index ec68bba9459bf2b73754a9ee1ec648022ebb1227..46893b31a2d05ac03c28d2105c2739d32d8972d1 100644 |
--- a/mojo/public/cpp/bindings/lib/router.cc |
+++ b/mojo/public/cpp/bindings/lib/router.cc |
@@ -62,13 +62,17 @@ bool Router::HandleIncomingMessageThunk::AcceptWithResponder( |
// ---------------------------------------------------------------------------- |
-Router::Router(ScopedMessagePipeHandle message_pipe, MojoAsyncWaiter* waiter) |
- : connector_(message_pipe.Pass(), waiter), |
+Router::Router(ScopedMessagePipeHandle message_pipe, |
+ FilterChain filters, |
+ MojoAsyncWaiter* waiter) |
+ : thunk_(this), |
+ filters_(filters.Pass()), |
+ connector_(message_pipe.Pass(), waiter), |
weak_self_(this), |
incoming_receiver_(NULL), |
- thunk_(this), |
next_request_id_(0) { |
- connector_.set_incoming_receiver(&thunk_); |
+ filters_.set_sink(&thunk_); |
+ connector_.set_incoming_receiver(filters_.GetHead()); |
} |
Router::~Router() { |