| 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() {
|
|
|